summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAram Drevekenin <aram@poor.dev>2022-11-17 19:55:41 +0100
committerAram Drevekenin <aram@poor.dev>2022-11-17 19:55:41 +0100
commit6ff2785f26701457e10577120918ff0de088a38e (patch)
tree6661236cf85e72481d78097bd0338bb4d219cf16
parentbca41afe1500df1cde9fad8b9520e4cf79aee672 (diff)
-rw-r--r--zellij-server/src/os_input_output.rs18
1 files changed, 12 insertions, 6 deletions
diff --git a/zellij-server/src/os_input_output.rs b/zellij-server/src/os_input_output.rs
index f6a0c9b44..07bd7c0f4 100644
--- a/zellij-server/src/os_input_output.rs
+++ b/zellij-server/src/os_input_output.rs
@@ -13,13 +13,15 @@ use nix::{
use signal_hook::consts::*;
use sysinfo::{ProcessExt, ProcessRefreshKind, System, SystemExt};
use zellij_utils::{
- channels,
- async_std,
+ async_std, channels,
data::Palette,
errors::prelude::*,
input::command::{RunCommand, TerminalAction},
interprocess,
- ipc::{ClientToServerMsg, IpcReceiverWithContext, IpcSenderWithContext, ServerToClientMsg, ExitReason},
+ ipc::{
+ ClientToServerMsg, ExitReason, IpcReceiverWithContext, IpcSenderWithContext,
+ ServerToClientMsg,
+ },
libc, nix,
shared::default_palette,
signal_hook,
@@ -347,16 +349,20 @@ impl ClientSender {
for msg in client_buffer_receiver.iter() {
let _ = sender.send(msg).with_context(err_context);
}
- let _ = sender.send(ServerToClientMsg::Exit(ExitReason::Error("Buffer full".to_string())));
+ let _ = sender.send(ServerToClientMsg::Exit(ExitReason::Error(
+ "Buffer full".to_string(),
+ )));
});
ClientSender {
client_id,
- client_buffer_sender
+ client_buffer_sender,
}
}
pub fn send_or_buffer(&self, msg: ServerToClientMsg) -> Result<()> {
let err_context = || format!("Client {} send buffer full", self.client_id);
- self.client_buffer_sender.try_send(msg).with_context(err_context)
+ self.client_buffer_sender
+ .try_send(msg)
+ .with_context(err_context)
}
}