time_sigil 0.0.2

task scheduler
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
33
34
35
36
37
38
39
40

mod fn_task;
mod runner;

pub use fn_task::fn_task;
pub use runner::{IntoTaskRunner, TaskRunner};

use crate::{queue::Handler, Error};

pub trait Task<T, Q> {
    fn run(&self, req: T) -> Q;
}

#[derive(Debug)]
pub struct OneWay<TPull, TPush> {
    pull: Handler<TPull>,
    push: Handler<TPush>,
}

impl<TPull, TPush> OneWay<TPull, TPush> {
    pub fn new(pull: Handler<TPull>, push: Handler<TPush>) -> Self {
        Self { pull, push }
    }

    pub async fn pull(&self) -> Result<Option<TPull>, Error> {
        self.pull.deque().await
    }

    pub async fn push(&self, res: TPush) -> Result<(), Error> {
        self.push.enque(res).await
    }
}

impl<T, Q> Clone for OneWay<T, Q> {
    fn clone(&self) -> Self {
        Self {
            pull: self.pull.clone(),
            push: self.push.clone(),
        }
    }
}