#async-write #sink #stream #async-read #networking #async-io #stream-sink

tokio-rw-stream-sink

Stream/Sink与AsyncRead/AsyncWrite之间的适配器

3个版本 (破坏性更新)

0.5.0 2021年11月21日
0.4.0 2021年11月17日
0.3.0 2021年11月17日

#35 in #async-write

MIT 许可证

7KB
82

此crate提供RwStreamSink类型。它包装了一个Stream和一个Sink,该包装器生成和接受字节数组,并实现了AsyncReadAsyncWrite特质。

每次调用AsyncWrite::poll_write都会向sink发送一个数据包。调用AsyncRead::poll_read将从stream的传入数据包中读取。


lib.rs:

此crate提供RwStreamSink类型。它包装了一个Stream和一个Sink,该包装器生成和接受字节数组,并实现了AsyncReadAsyncWrite

每次调用AsyncWrite::poll_write都会向sink发送一个数据包。调用AsyncRead::poll_read将从stream的传入数据包中读取。

依赖关系

~2.8–4MB
~64K SLoC