flock 0.2.0

Parallel runner for asynchronous tasks.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use std::hash::Hash;

use event::{Command, Syscall};

pub trait Kernel: Sized {
    type Token: Clone + Send + Hash + Eq + 'static;
    type Data: Clone + Send + 'static;
    type OpenParam: Send + 'static;
    type Sink: Sink<Item = Syscall<Self>> + Send + 'static;

    fn create_token() -> Self::Token;

    fn create_sink(&self) -> Self::Sink;

    fn run<F>(&self, callback: F) where F: FnMut(Command<Self>);
}

pub trait Sink {
    type Item: Send;

    fn post(&self, msg: Self::Item);
}