time_sigil 0.0.1

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

pub use errors::Error;
pub use queue::{Queue, Server};
pub use task::{Task, TaskRunner};
pub use tokio_util::sync::CancellationToken;

mod errors;
pub mod http;
mod queue;
pub mod schedule;
pub mod service;
mod task;

#[cfg(test)]
mod tests {
    use crate::{service::new, CancellationToken};
    use std::collections::VecDeque;

    #[tokio::test]
    async fn test() {
        let (runner, handler) = new(
            VecDeque::<i32>::new(),
            VecDeque::<i32>::new(),
            |x: i32| x + 1,
            4,
        );
        let cancel = CancellationToken::new();
        tokio::spawn(runner.listen(cancel.clone()));

        handler.push_task(0).await.unwrap();

        while let Ok(Some(x)) = handler.pop_result().await {
            assert_eq!(x, 1);
            cancel.cancel();
        }
    }
}