dope 0.2.2

Thin io_uring adaptor with "Manifolds"
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

cfg_select! { target_os = "linux" => {
mod linux {
    use dope_futures::listener::Listener;
    use dope_futures::stream::Stream;
    use dope_transport::Tcp;
    use dope_runtime::executor::{block_on, spawn};

    const ACCEPTS: usize = 64;

    #[test]
    fn multishot_accept_many_connections() {
        let mut listener = Listener::<Tcp>::bind("127.0.0.1:0").unwrap();
        let addr = listener.local_addr().unwrap();

        block_on(async move {
            let server = spawn(async move {
                for _ in 0..ACCEPTS {
                    let (_tcp, _peer) = listener.accept().await.expect("accept");
                }
            });

            for _ in 0..ACCEPTS {
                let _ = Stream::<Tcp>::connect_with(addr).await.expect("connect");
            }

            server.await;
        });
    }
}
} _ => {} }