Loading src/lib.rs +3 −3 Original line number Diff line number Diff line Loading @@ -18,16 +18,16 @@ impl Server { } pub fn start(&self) { let listener = TcpListener::bind(self.address).unwrap(); let listener = TcpListener::bind(&self.address).unwrap(); for stream in listener.incoming() { let stream = stream.unwrap(); self.pool.execute(|| { self.handle_connection(stream); Server::handle_connection(stream); }); } } fn handle_connection(&self, mut stream: TcpStream) { fn handle_connection(mut stream: TcpStream) { let mut buffer = [0; 512]; stream.read(&mut buffer).unwrap(); Loading src/main.rs +1 −1 Original line number Diff line number Diff line Loading @@ -2,6 +2,6 @@ extern crate server; use server::Server; fn main() { let server = Server::new(String::from("127.0.0.1:7878")); let server = Server::new(String::from("127.0.0.1:7878"), 4); server.start(); } src/threadpool.rs +1 −1 Original line number Diff line number Diff line Loading @@ -34,7 +34,7 @@ impl ThreadPool { } } pub fn execute<F>(self, f: F) pub fn execute<F>(&self, f: F) where F: FnOnce() + Send + 'static { Loading Loading
src/lib.rs +3 −3 Original line number Diff line number Diff line Loading @@ -18,16 +18,16 @@ impl Server { } pub fn start(&self) { let listener = TcpListener::bind(self.address).unwrap(); let listener = TcpListener::bind(&self.address).unwrap(); for stream in listener.incoming() { let stream = stream.unwrap(); self.pool.execute(|| { self.handle_connection(stream); Server::handle_connection(stream); }); } } fn handle_connection(&self, mut stream: TcpStream) { fn handle_connection(mut stream: TcpStream) { let mut buffer = [0; 512]; stream.read(&mut buffer).unwrap(); Loading
src/main.rs +1 −1 Original line number Diff line number Diff line Loading @@ -2,6 +2,6 @@ extern crate server; use server::Server; fn main() { let server = Server::new(String::from("127.0.0.1:7878")); let server = Server::new(String::from("127.0.0.1:7878"), 4); server.start(); }
src/threadpool.rs +1 −1 Original line number Diff line number Diff line Loading @@ -34,7 +34,7 @@ impl ThreadPool { } } pub fn execute<F>(self, f: F) pub fn execute<F>(&self, f: F) where F: FnOnce() + Send + 'static { Loading