lio 0.4.1

A platform-independent async I/O library with native support for io_uring (Linux), IOCP (Windows), and kqueue (macOS)
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

use lio::Lio;
use lio::api::resource::Resource;

#[test]
fn test_worker_start_stop() {
  let mut lio = Lio::new(64).unwrap();

  let thing = "hello".as_bytes().to_vec();

  let fd = Resource::stdout();

  let (sender, receiver) = std::sync::mpsc::channel();

  lio::api::write(&fd, thing).with_lio(&mut lio).send_with(sender);

  // Poll until done
  loop {
    lio.try_run().unwrap();
    if let Ok((res, _buf)) = receiver.try_recv() {
      res.unwrap();
      break;
    }
    std::thread::sleep(std::time::Duration::from_micros(100));
  }
}