async-socket

此crate实现了一个通用异步套接字。

Socket实现了AsyncRead、AsyncWrite、Stream和Clone traits，从而模仿了TcpStream和UnixStream对象的功能和行为。这些特性使其成为测试网络活动和事件的理想工具。

用法

示例

use async_socket::Socket;
use async_std::task::spawn;
use futures::io::AsyncWriteExt;
use futures::stream::StreamExt;

async fn example() {
    let mut stream = Socket::default();
    let mut writer = stream.clone();

    spawn(async move {
        writer.write(b"Hello").await.unwrap();
    });

    while let Some(bytes) = stream.next().await {
        // ...
    }
}

许可证：MIT