tokio_kcp

tokio_kcp copied to clipboard

send队列长度超过128时只阻塞不报错

7

在没有接收方的时候，一直发送数据包 ```rust let server_addr = "127.0.0.1:5555".parse::().unwrap(); //没有程序监听这个端口 let mut stream = KcpStream::connect(&config, server_addr).await.unwrap(); let mut s = 1; loop { println!("sending{s}"); stream.send(&buffer).await.unwrap(); println!("sent{s}"); s += 1; tokio::time::sleep(std::time::Duration::from_millis(1)).await; } ``` 输出：...

TheCGDF