rotor 0.6.3

The mio-based framework for doing I/O in simple and composable way
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 {Notify, Port, Future};

impl<T:Sized> Port<T> {
    /// Set the value of the future
    ///
    /// # Panics
    ///
    /// Panics when message to the target main loop can't be sent
    pub fn set(self, value: T) {
        *self.contents.lock()
            .expect("Lock of the future is poisoned") = Some(value);
        self.channel.send(Notify::Fsm(self.token))
            .expect("Target channel for the future is full");
    }
}

impl<T:Sized> Future<T> {
    /// Get the value consuming the future
    ///
    /// # Panics
    ///
    /// Panics when no value is set yet
    pub fn get(self) -> T {
        self.contents.lock().expect("Lock of the future is poisoned")
        .take().expect("Future is not resolved yet")
    }
    pub fn done(&self) -> bool {
        self.contents.lock()
            .expect("Lock of the future is poisoned").is_some()
    }
}