- // Block forever, handling each request that arrives at this IP address
- for stream in listener.incoming() {
- let stream = stream.unwrap();
- // not concurrent
- handle_connection(stream).await;
- }
+ listener.incoming().for_each_concurrent(/* limit */ None, |tcpstream| async move {
+ let tcpstream = tcpstream.unwrap();
+ handle_connection(tcpstream).await;
+ }).await;