tokio_kcp
tokio_kcp copied to clipboard
Matrix-Zhang
A Kcp implementation for tokio
It is hard to understand code in this repo. Can you add some doc about this repo.
I've been playing with this crate, but I can't get my read loop to stop (when it reads `0` bytes, like in your example). On the client-side, I'm writing 80...
https://docs.rs/tokio/latest/src/tokio/net/tcp/listener.rs.html#177-192
Firstly, thanks for the great repository! Currently, tokio_kcp can't communicate with [kcp-go](https://github.com/xtaci/kcp-go/) because: beside kcp, kcp-go also adds other features that change its protocol header, e.g. crypto, crc, fec. It...
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...
Updates dependency to the patch version of 0.9.8 [Advisory](https://rustsec.org/advisories/RUSTSEC-2023-0031.html)
The underlying transport protocol of kcp implemented by this crate is udp I found a phenomenon during actual use: for the same udp connection (UDP data channel determined by source...
I am trying to port this crate to async_std, but my limited Rust knowledge left a bug somewhere. If any maintainer have time, feel free to have a look. Thank...
空data支持
当客户端发送一个空的数据包时： ```rust let mut buffer = [0u8; 0]; ... stream.write_all(&buffer).await.unwrap(); ``` 服务端的`read`会卡住，或者说，忽略这个空数据包 ```rust while let Ok(n) = stream.read(&mut buffer).await { ... } ``` 这导致一些兼容性问题。 以及[某些kcp库](https://github.com/MirrorNetworking/kcp2k)的client在connect时会发送一个空数据包作为握手。 是否有办法接受空数据包？
