From 218da36b4f963a5dfcd619d543cb95c5c196d214 Mon Sep 17 00:00:00 2001 From: metamuffin Date: Sun, 11 Aug 2024 01:30:59 +0200 Subject: update movement in protocol and all clients --- server/client-lib/src/network/sync.rs | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) (limited to 'server/client-lib/src/network/sync.rs') diff --git a/server/client-lib/src/network/sync.rs b/server/client-lib/src/network/sync.rs index e8aa08de..3a475e01 100644 --- a/server/client-lib/src/network/sync.rs +++ b/server/client-lib/src/network/sync.rs @@ -80,7 +80,7 @@ impl Network { }) } - pub fn poll(&mut self) { + pub fn poll(&mut self) -> anyhow::Result<()> { loop { self.queue_in.extend(match self.sock.read() { Ok(Message::Text(packet)) => match serde_json::from_str(&packet) { @@ -131,18 +131,16 @@ impl Network { for packet in self.queue_out.drain(..) { debug!("-> {packet:?}"); if self.use_bincode { - self.sock - .write(Message::Binary( - bincode::encode_to_vec(&packet, BINCODE_CONFIG).unwrap(), - )) - .unwrap(); + self.sock.write(Message::Binary( + bincode::encode_to_vec(&packet, BINCODE_CONFIG).unwrap(), + ))?; } else { self.sock - .write(Message::Text(serde_json::to_string(&packet).unwrap())) - .unwrap(); + .write(Message::Text(serde_json::to_string(&packet).unwrap()))?; } } self.sock.flush().unwrap(); + Ok(()) } } -- cgit v1.2.3-70-g09d2