ARCHIVED ARCHIVED ARCHIVED

This crate is archived and will not be updated.

The code is now at safina::net in the safina crate.

safina-net

This is a safe Rust library for network communication.

It is part of safina, a safe async runtime.

Features

• forbid(unsafe_code)
• Depends only on std
• Good test coverage (91%)
• Works with safina-executor or any async executor

Limitations

• No AsyncRead or AsyncWrite implementations yet.
• Unoptimized. Uses polling. This has more latency and CPU load than other async networking libraries.
• TCP connect uses a blocking thread. Concurrent connect operations are limited by executor's blocking thread pool size.

Examples

let bind_addr =
    std::net::SocketAddr::from(([127, 0, 0, 1], 0));
let mut listener =
    safina_net::TcpListener::bind(&bind_addr)
    .unwrap();
let addr = listener.inner().local_addr().unwrap();
println!("{}", &addr);

let executor = safina_executor::Executor::default();
executor.spawn(async move {
    let mut tcp_stream =
        safina_net::TcpStream::connect(addr)
        .await
        .unwrap();
    let mut buf = String::new();
    tcp_stream.read_to_string(&mut buf).await.unwrap();
    println!("read {:?}", buf);
});

let (mut tcp_stream, _addr)
    = listener.accept().await.unwrap();
tcp_stream.write_all(b"response").await.unwrap();
println!("wrote response");

For complete examples, see the integration tests in tests/.

Alternatives

• async-net
  • Dependencies are full of unsafe
• async-io
  • Full of unsafe
• tokio
  • Very popular
  • Fast
  • Internally incredibly complicated
  • Full of unsafe
• tcp-stream
  • Blocks async executor threads
  • Contains a little unsafe code

Changelog

TO DO

• Add additional crates with adapters to popular async io traits, like safina-net-tokio, safina-net-futures, etc.