compio 0.18.0

Completion based 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
55
56
57
58
59

use compio::{
    BufResult,
    io::{AsyncReadExt, AsyncWriteExt},
};

#[compio::main]
async fn main() {
    #[cfg(windows)]
    {
        use compio::fs::named_pipe::{ClientOptions, ServerOptions};

        const PIPE_NAME: &str = r"\\.\pipe\compio-named-pipe";

        let mut server = ServerOptions::new()
            .access_inbound(false)
            .create(PIPE_NAME)
            .unwrap();
        let mut client = ClientOptions::new()
            .write(false)
            .open(PIPE_NAME)
            .await
            .unwrap();

        server.connect().await.unwrap();

        let write = server.write_all("Hello world!");
        let buffer = Vec::with_capacity(12);
        let read = client.read_exact(buffer);

        let (BufResult(write, _), BufResult(read, buffer)) = futures_util::join!(write, read);
        write.unwrap();
        read.unwrap();
        println!("{}", String::from_utf8(buffer).unwrap());
    }
    #[cfg(unix)]
    {
        use compio::fs::pipe::OpenOptions;
        use nix::{sys::stat::Mode, unistd::mkfifo};
        use tempfile::tempdir;

        let dir = tempdir().unwrap();
        let file = dir.path().join("compio-named-pipe");

        mkfifo(&file, Mode::S_IRWXU).unwrap();
        let options = OpenOptions::new();
        let (mut rx, mut tx) =
            futures_util::try_join!(options.open_receiver(&file), options.open_sender(&file))
                .unwrap();

        let write = tx.write_all("Hello world!");
        let buffer = Vec::with_capacity(12);
        let read = rx.read_exact(buffer);

        let (BufResult(write, _), BufResult(read, buffer)) = futures_util::join!(write, read);
        write.unwrap();
        read.unwrap();
        println!("{}", String::from_utf8(buffer).unwrap());
    }
}