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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

use std::net::Shutdown;

use completeio::net::{UnixListener, UnixStream};

#[test]
fn accept_read_write() -> std::io::Result<()> {
    completeio::task::block_on(async {
        let dir = tempfile::Builder::new()
            .prefix("completeio-uds-tests")
            .tempdir()
            .unwrap();
        let sock_path = dir.path().join("connect.sock");

        let listener = UnixListener::bind(&sock_path)?;

        let client = UnixStream::connect(&sock_path)?;
        let (server, _) = listener.accept().await?;

        let write_len = client.send_all("hello").await.0?;
        assert_eq!(write_len, 5);
        drop(client);

        let buf = Vec::with_capacity(5);
        let (res, buf) = server.recv_exact(buf).await;
        assert_eq!(res.unwrap(), 5);
        assert_eq!(&buf[..], b"hello");
        let len = server.recv(buf).await.0?;
        assert_eq!(len, 0);
        Ok(())
    })
}

#[test]
fn shutdown() -> std::io::Result<()> {
    completeio::task::block_on(async {
        let dir = tempfile::Builder::new()
            .prefix("completeio-uds-tests")
            .tempdir()
            .unwrap();
        let sock_path = dir.path().join("connect.sock");

        let listener = UnixListener::bind(&sock_path)?;

        let client = UnixStream::connect(&sock_path)?;
        let (server, _) = listener.accept().await?;

        // Shut down the client
        client.shutdown(Shutdown::Both)?;
        // Read from the server should return 0 to indicate the channel has been closed.
        let n = server.recv(Vec::with_capacity(1)).await.0?;
        assert_eq!(n, 0);
        Ok(())
    })
}