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; } } }