summaryrefslogtreecommitdiff
path: root/server/src/network.rs
diff options
context:
space:
mode:
Diffstat (limited to 'server/src/network.rs')
-rw-r--r--server/src/network.rs4
1 files changed, 2 insertions, 2 deletions
diff --git a/server/src/network.rs b/server/src/network.rs
index 211d0bc..64bcf63 100644
--- a/server/src/network.rs
+++ b/server/src/network.rs
@@ -73,7 +73,7 @@ impl ServerNetwork {
}
};
spawn(move || {
- if let Err(e) = handle_conn_write(conn, sock2, send_rx) {
+ if let Err(e) = handle_conn_write(sock2, send_rx) {
warn!("client outbound error: {e}");
}
});
@@ -183,7 +183,7 @@ fn handle_conn_read(conn: u128, sock: TcpStream, tx: Sender<(u128, Packet)>) ->
tx.send((conn, packet)).unwrap();
}
}
-fn handle_conn_write(conn: u128, sock: TcpStream, rx: Receiver<Arc<Vec<u8>>>) -> Result<()> {
+fn handle_conn_write(sock: TcpStream, rx: Receiver<Arc<Vec<u8>>>) -> Result<()> {
let mut sock = BufWriter::new(sock);
for packet in rx {
sock.write_all(&packet)?;