()
| 3 | use std::thread; |
| 4 | |
| 5 | fn main() { |
| 6 | let listener = TcpListener::bind("127.0.0.1:12321").unwrap(); |
| 7 | for stream in listener.incoming() { |
| 8 | let stream = stream.unwrap(); |
| 9 | thread::spawn(move || handle_client(stream)); |
| 10 | } |
| 11 | } |
| 12 | |
| 13 | fn handle_client(stream: TcpStream) { |
| 14 | let mut stream = BufReader::new(stream); |
nothing calls this directly
no test coverage detected