From 87416e5af9de8a58d77c192e79f55b52f8182a70 Mon Sep 17 00:00:00 2001 From: Mika Date: Sun, 13 Oct 2024 22:43:23 +0200 Subject: [PATCH] added loop to listener --- crates/backend/src/main.rs | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/crates/backend/src/main.rs b/crates/backend/src/main.rs index de98cb3..1be2e76 100644 --- a/crates/backend/src/main.rs +++ b/crates/backend/src/main.rs @@ -53,11 +53,17 @@ async fn main() -> std::io::Result<()> { loop { if let Ok((mut stream, _)) = listener.accept().await { let mut buffer = vec![0; 1024]; - if let Ok(size) = stream.read(&mut buffer).await { - buffer.truncate(size); - if let Ok((data, _)) = Data::from_bytes((&buffer, 0)) { - println!("Received: {:?}", data); - // Process the data or save it to the database + loop { + if let Ok(size) = stream.read(&mut buffer).await { + buffer.truncate(size); + if let Ok((data, _)) = Data::from_bytes((&buffer, 0)) { + println!("Received: {:?}", data); + // Process the data or save it to the database + } else { + println!("Failed to parse data"); + } + } else { + break; } } }