periodically 0.2.0

A library for running tasks on a schedule
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

use periodically::{AsyncTask, Task};
use std::{
    future::ready,
    sync::{
        atomic::{AtomicUsize, Ordering},
        Arc,
    },
};

#[derive(Default)]
pub struct SpyingTask {
    count: Arc<AtomicUsize>,
}

impl SpyingTask {
    pub fn counter(&self) -> Arc<AtomicUsize> {
        self.count.clone()
    }
}

impl Task for SpyingTask {
    fn run(&self) -> () {
        self.count.fetch_add(1, Ordering::Relaxed);
    }
}

impl AsyncTask for SpyingTask {
    fn run(&self) -> impl std::future::Future<Output = ()> + Send {
        self.count.fetch_add(1, Ordering::Relaxed);
        ready(())
    }
}