monoio 0.2.4

A thread per core runtime based on iouring.
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

use monoio::{
    io::{AsyncReadRent, AsyncWriteRent, BufReader, BufWriter, Splitable},
    net::{TcpListener, TcpStream},
};

#[monoio::test_all]
async fn ensure_buf_writter_write_properly() {
    let srv = TcpListener::bind("127.0.0.1:0").unwrap();
    let addr = srv.local_addr().unwrap();

    monoio::spawn(async move {
        let stream = TcpStream::connect(&addr).await.unwrap();
        let (_, stream_write) = stream.into_split();

        let mut buf_w = BufWriter::new(stream_write);
        assert!(buf_w.write(b"1").await.0.is_ok());
        assert!(buf_w.write(b"2").await.0.is_ok());
        assert!(buf_w.write(b"3").await.0.is_ok());
        assert!(buf_w.flush().await.is_ok());
    });

    let (stream, _) = srv.accept().await.unwrap();
    let (rd, _) = stream.into_split();

    let s: Vec<u8> = Vec::with_capacity(16);
    let mut buf = BufReader::new(rd);
    let (size, s) = buf.read(s).await;

    assert!(size.is_ok());
    assert_eq!(s, b"123");
}