simple-async-pipe

旨在为异步代码提供类似管道的功能。创建用于测试。未进行性能优化。

文档

许可证

本项目许可采用以下任一许可证：

• Apache 许可证 2.0 版本，(LICENSE-APACHE 或 https://apache.ac.cn/licenses/LICENSE-2.0)
• MIT 许可证 (LICENSE-MIT 或 http://opensource.org/licenses/MIT)

由您选择。

lib.rs:

旨在为异步代码提供类似管道的功能。

示例

    let (mut reader, mut writer) = simple_async_pipe::pipe(64);

    let message = b"hello world";
    writer.write_all(message).await.unwrap();

    let mut buffer = vec![0u8; message.len()];
    reader.read_exact(&mut buffer).await.unwrap();
    assert_eq!(&buffer, message);