may 0.3.51

Rust Stackful Coroutine Library
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

//! coroutine io utilities

#[cfg(unix)]
#[path = "sys/unix/mod.rs"]
pub(crate) mod sys;

#[cfg(windows)]
#[path = "sys/windows/mod.rs"]
pub(crate) mod sys;

// export the generic IO wrapper
pub mod co_io_err;

mod event_loop;
pub(crate) mod split_io;
pub(crate) mod thread;

use std::ops::Deref;

pub(crate) use self::event_loop::EventLoop;
#[cfg(feature = "io_cancel")]
pub(crate) use self::sys::cancel;
pub use self::sys::co_io::CoIo;
#[cfg(unix)]
pub use self::sys::wait_io::{WaitIo, WaitIoWaker};
pub use self::sys::IoData;
pub(crate) use self::sys::{add_socket, net, Selector};
pub use split_io::{SplitIo, SplitReader, SplitWriter};

pub trait AsIoData {
    fn as_io_data(&self) -> &IoData;
}

// an option type that implement deref
struct OptionCell<T>(Option<T>);

impl<T> Deref for OptionCell<T> {
    type Target = T;
    fn deref(&self) -> &T {
        match self.0.as_ref() {
            Some(d) => d,
            None => panic!("no data to deref for OptionCell"),
        }
    }
}

impl<T> OptionCell<T> {
    pub fn new(data: T) -> Self {
        OptionCell(Some(data))
    }

    pub fn take(&mut self) -> T {
        match self.0.take() {
            Some(d) => d,
            None => panic!("no data to take for OptionCell"),
        }
    }
}