async-pipe 0.1.3

Creates an asynchronous piped reader and writer pair using tokio.rs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

use std::task::Waker;

pub(crate) struct State {
    pub(crate) reader_waker: Option<Waker>,
    pub(crate) writer_waker: Option<Waker>,
    pub(crate) data: Option<Data>,
    pub(crate) done_reading: bool,
    pub(crate) read: usize,
    pub(crate) done_cycle: bool,
    pub(crate) closed: bool,
}

pub(crate) struct Data {
    pub(crate) ptr: *const u8,
    pub(crate) len: usize,
}

unsafe impl Send for Data {}