kernel 1.1.0

Abstract Reactive Streams
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


// O-STREAMS

#[derive(PartialEq,Debug, Clone)]
pub enum Async<T> {
    Ready(T),
    NotReady,
}

impl<T> Async<T> {
    #[inline]
    pub fn unwrap(self) -> T {
        match self {
            Async::Ready(val) => val,
            Async::NotReady => panic!("called `Async::unwrap()` on a `None` value"),
        }
    }
}

#[derive(Debug)]
pub enum Error {
    NotImplemented,
    RuntimeError,
}

pub type Poll<T> = Result<Async<T>, Error>;