completeio 0.1.0

Completion based IO drivers and async runtime
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

use completeio::net::{TcpListener, TcpStream, ToSockAddrs};

async fn test_impl(addr: impl ToSockAddrs) {
    let listener = TcpListener::bind(addr).unwrap();
    let addr = listener.local_addr().unwrap();
    let (tx, rx) = futures_channel::oneshot::channel();
    completeio::task::spawn(async move {
        let (socket, _) = listener.accept().await.unwrap();
        assert!(tx.send(socket).is_ok());
    })
    .detach();
    let cli = TcpStream::connect(&addr).await.unwrap();
    let srv = rx.await.unwrap();
    assert_eq!(cli.local_addr().unwrap(), srv.peer_addr().unwrap());
}

macro_rules! test_accept {
    ($(($ident:ident, $target:expr),)*) => {
        $(
            #[test]
            fn $ident() {
                println!("Testing {}...", stringify!($ident));
                completeio::task::block_on(test_impl($target))
            }
        )*
    };
}

test_accept! {
    (ip_str, "127.0.0.1:0"),
    (host_str, "localhost:0"),
    (socket_addr, "127.0.0.1:0".parse::<std::net::SocketAddr>().unwrap()),
    (str_port_tuple, ("127.0.0.1", 0)),
    (ip_port_tuple, ("127.0.0.1".parse::<std::net::IpAddr>().unwrap(), 0)),
}