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
27
28
29
30
31
32

// Generic type holds all implemetors of Task trait.

use reactors::task::{self, Poll, Context, Task};
use reactors::cps::CpsTask;
use reactors::scheduler::Scheduler;

pub enum Job<'a> {
    Cps(CpsTask<'a>),
}

impl<'a> Job<'a> {
    pub fn unwrap(&'a mut self) -> &'a mut Task<'a> {
        match *self {
            Job::Cps(ref mut c) => c,
        }
    }
}

impl<'a> Task<'a> for Job<'a> {
    fn init(&'a mut self, input: Option<&'a str>, task_id: usize) {
        self.unwrap().init(input, task_id)
    }
    fn exec(&'a mut self, input: Option<&'a str>) {
        self.unwrap().exec(input)
    }
    fn poll(&'a mut self, c: Context<'a>, sched: &'a Scheduler<'a>) -> Poll<Context<'a>, task::Error> {
        self.unwrap().poll(c, sched)
    }
    fn finalize(&'a mut self) {
        self.unwrap().finalize()
    }
}