From 8ebba7271c1cb0cce03b37043e282007f43f8e11 Mon Sep 17 00:00:00 2001 From: break27 Date: Fri, 7 Jun 2024 17:56:43 +0800 Subject: [PATCH] fix: client shutdown --- src/server.rs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/server.rs b/src/server.rs index 453d593..9069c98 100644 --- a/src/server.rs +++ b/src/server.rs @@ -21,16 +21,18 @@ impl Server { let agent = agent.clone(); let (mut inbound, addr) = listener.accept().await?; - log::info!("*** Incoming connection from {}", addr); + log::info!("*** Incoming connection from {addr}"); async_std::task::spawn(async move { if let Err(e) = agent.handle(&mut inbound).await { - log::error!("Agent: {}", e); + log::error!("Agent: {e}"); let resp = http::Response::from_err(e); inbound.write(resp.to_string().as_bytes()).await.unwrap(); inbound.flush().await.unwrap(); } + + let _ = inbound.shutdown(std::net::Shutdown::Both); }); } }