diff --git a/src/connections.rs b/src/connections.rs index 18fdf93..afb76e3 100644 --- a/src/connections.rs +++ b/src/connections.rs @@ -234,7 +234,7 @@ impl ConnectionManager { let now = Instant::now(); - self.connections.retain(|addr, conn| { + self.connections.retain(|_, conn| { let retain = match conn.state { ConnectionState::ReceivingClosing => { if (now - conn.last_recv_close) > Duration::from_millis(500) { @@ -253,8 +253,6 @@ impl ConnectionManager { retain }); - for (addr, conn) in &self.connections {} - messages } } @@ -287,14 +285,10 @@ impl UdpWrapper { if buf.len() > DATAGRAM_SIZE { return Err(SendError::DatagramTooLarge(buf.len())); } - let res = socket + socket .send_to(&buf, addr) .map_err(|e| SendError::SendError(e)) - .map(|_| ()); - if let Ok(_) = res { - println!("Sent: {:?}", package); - } - res + .map(|_| ()) } else { Err(SendError::SocketDisconnected) } diff --git a/src/listener.rs b/src/listener.rs index bea256c..8f73023 100644 --- a/src/listener.rs +++ b/src/listener.rs @@ -28,7 +28,6 @@ impl Listener { let mut ciborium_buf: Datagram = [0; _]; let bytes = Cursor::new(&mut buffer[..num_bytes]); let res = ciborium::from_reader_with_buffer::(bytes, &mut ciborium_buf); - println!("Received: {:?}", res); match res { Ok(pkg) => self.sender.send(ListenerMessage::Package(pkg, from_addr)), Err(_) => self.sender.send(ListenerMessage::PackageError(