From 645f53d13e336041472917e6cf33297bddd8911d Mon Sep 17 00:00:00 2001 From: Daniel Heras Quesada Date: Tue, 22 Jul 2025 22:06:49 +0200 Subject: [PATCH] feat: response threaded --- src/http/server.rs | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/src/http/server.rs b/src/http/server.rs index 4cd1c0c..295cb0b 100644 --- a/src/http/server.rs +++ b/src/http/server.rs @@ -1,7 +1,7 @@ use std::collections::HashMap; -use std::fs; use std::io::prelude::*; use std::net::{SocketAddr, TcpListener, TcpStream}; +use std::{fs, thread}; use super::*; @@ -110,12 +110,15 @@ impl HttpApp<'_> { for stream in listener.incoming() { let mut _stream = stream.unwrap(); + println!("Connection established!"); let response = self.process_petition(&mut _stream); - // TODO: manage error case - let _amount = _stream.write(response.data.as_bytes()).unwrap(); - _stream.flush().unwrap(); + thread::spawn(move || { + // TODO: manage error case + _stream.write(response.data.as_bytes()).unwrap(); + _stream.flush().unwrap(); + }); } } }