event 0.2.1

A mulit-threaded event loop for Rust
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

use handler::Handler;
use std::thunk::Invoke;
use std::time::duration::Duration;

pub enum Registration {
    Handler(Box<Handler>),
    Timeout(Box<Invoke + 'static>, Duration),
    Next(Box<Invoke + 'static>)
}

// This is an *incorrect* implementation, in the sense that
// sending a Registration can be incorrect. However, we
// only send Registration and its contents around a single
// thread so it is ok for us to fake Send to fool mio.
unsafe impl Send for Registration {}

impl Registration {
    pub fn new(handler: Box<Handler>) -> Registration {
        Registration::Handler(handler)
    }

    pub fn timeout<F: FnOnce() + 'static>(callback: F, timeout: Duration) -> Registration {
        Registration::Timeout(box move |:_| { callback() }, timeout)
    }

    pub fn next<F: FnOnce() + 'static>(callback: F) -> Registration {
        Registration::Next(box move |:_| { callback() })
    }
}