From 190cc8f238fe512a97e9cf4b84d6a329cf2524d3 Mon Sep 17 00:00:00 2001 From: Luuk van Oijen Date: Wed, 8 Nov 2023 11:47:23 +0100 Subject: [PATCH] Update mod.rs --- src/server/mod.rs | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/server/mod.rs b/src/server/mod.rs index c473bb7..da9e322 100644 --- a/src/server/mod.rs +++ b/src/server/mod.rs @@ -72,9 +72,11 @@ impl Server { let connect_runtime_handle = tokio::spawn(async move { loop { match tcp_listener_ref.accept().await { - Ok((socket, addr)) => { + Ok((mut socket, addr)) => { info!("New client connected: {:?}", addr); + socket.set_nodelay(true); + let mut client = Client::new(socket); match client.authenticate(&config_ref).await { Ok(_) => { @@ -182,8 +184,9 @@ impl Server { } } } + for (i, packet) in packets { - self.parse_packet(i, packet).await? + self.parse_packet(i, packet).await?; } // I'm sorry for this code :(