daemon/ipc.rs

@@ -1,11 +1,13 @@
 use std::{
     collections::{BTreeMap, HashMap},
+    net::SocketAddr,
+    os::linux::net::SocketAddrExt,
     path::PathBuf,
     str::FromStr,
 };
 
 use crate::socket::{create_niri_socket, tell};
-use anyhow::{Result, anyhow};
+use anyhow::{Error, Result, anyhow};
 use microxdg::Xdg;
 use niri_ipc::{Event, Request};
 use niri_tag::{TagCmd, TagEvent, TagState};
@@ -14,7 +16,7 @@ use nix::unistd::geteuid;
 use smol::{
     channel::{self},
     future,
-    io::{AsyncBufReadExt, AsyncWriteExt, BufReader},
+    io::{AsyncBufReadExt, AsyncWriteExt, BufReader, BufWriter},
     net::unix::{UnixListener, UnixStream},
     stream::StreamExt,
 };

daemon/manager.rs

@@ -353,12 +353,7 @@ impl NiriTag {
             },
         };
         // then arrange corresponding state in the compositor
-        self.do_action(action).await?;
-        tell(
-            &mut self.socket,
-            Request::Action(Action::CenterVisibleColumns {}),
-        )
-        .await
+        self.do_action(action).await
     }
 
     async fn handle_event(&mut self, ev: Event) -> Result<()> {