let listener = TcpListener::bind("127.0.0.1:7878").unwrap();
let pool = ThreadPool::new(4);
- for stream in listener.incoming() {
+ for stream in listener.incoming() /* for testing cleanup: .take(2) */ {
let stream = stream.unwrap();
pool.execute(|| handle_connection(stream));
}