Async fn handle_con(socket: TcpStream) { println!("New socket

connected: {socket:?}");
let mut reader = BufReader::new(socket);
let mut buf = String::new();


loop {
let bytes_read = reader.read_line(&mut buf).await.expect("Couldn't read data. [Err: bytes_read]");

if bytes_read == 0 {
break;
}
buf.pop();
println!("Got from peer: {buf}");


buf.clear();
}

println!("Peer has closed connection");
}

точно блокирует? просто вроде ничего такого нет