diff options
Diffstat (limited to 'server')
-rw-r--r-- | server/src/network.rs | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/server/src/network.rs b/server/src/network.rs index c59b54b..ec65218 100644 --- a/server/src/network.rs +++ b/server/src/network.rs @@ -66,7 +66,7 @@ impl ServerNetwork { continue; } } - if let Err(_) = tcp.send(ser.clone()) { + if tcp.send(ser.clone()).is_err() { warn!("{cid}: queue full, packet dropped") } } @@ -82,7 +82,7 @@ impl ServerNetwork { } } debug!("{conn} -> {packet:?}"); - if let Err(_) = tcp.send(ser.clone()) { + if tcp.send(ser.clone()).is_err() { warn!("{conn}: queue full, packet dropped") } } @@ -220,12 +220,12 @@ fn handle_conn_write(sock: TcpStream, rx: Receiver<Arc<Vec<u8>>>) -> Result<()> } impl ServerNetwork { - pub fn br<'a>(&'a self) -> Broadcaster<'a> { + pub fn br(&self) -> Broadcaster<'_> { Broadcaster(self) } } pub struct Broadcaster<'a>(&'a ServerNetwork); -impl<'a> PacketSink for Broadcaster<'a> { +impl PacketSink for Broadcaster<'_> { fn push(&mut self, p: Packet) { self.0.broadcast(p, true); } |