|
|
@ -382,7 +382,7 @@ where |
|
|
|
R: RecvServerPacket + std::fmt::Debug + Send + Sync + 'static,
|
|
|
|
E: std::fmt::Debug + Send,
|
|
|
|
{
|
|
|
|
let listener = async_std::task::spawn(async move {
|
|
|
|
async_std::task::spawn(async move {
|
|
|
|
let listener = async_std::net::TcpListener::bind(&std::net::SocketAddr::from((std::net::Ipv4Addr::new(0,0,0,0), client_port))).await.unwrap();
|
|
|
|
let mut id = 1;
|
|
|
|
|
|
|
@ -405,9 +405,7 @@ where |
|
|
|
client_recv_loop(client_id, socket.clone(), cipher_in.clone(), server_state_sender.clone(), client_sender).await;
|
|
|
|
client_send_loop(client_id, socket.clone(), cipher_in.clone(), cipher_out.clone(), client_receiver).await;
|
|
|
|
}
|
|
|
|
});
|
|
|
|
|
|
|
|
listener
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|