summaryrefslogtreecommitdiff
path: root/server
diff options
context:
space:
mode:
Diffstat (limited to 'server')
-rw-r--r--server/src/network.rs8
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);
}