KcpSession io_task_handle loop 不结束 #33
Description
server模式下， 循环不结束，是否应该添加 input_rx.recv() 失败时结束循环？
let io_task_handle = {
let session = session.clone();
tokio::spawn(async move {
let mut input_buffer = [0u8; 65536];
loop {
tokio::select! {
recv_result = udp_socket.recv(&mut input_buffer), if is_client => {
...
}
// bytes received from listener socket
input_opt = input_rx.recv() => {
...
} else {
// 这里结束循环？？？
break;
}
}
}
}
})
};