ticked_async_executor 0.2.0

Local executor that runs woken async tasks when it is ticked
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

pub struct TickedTimer {
    pub tick_recv: tokio::sync::watch::Receiver<f64>,
}

impl TickedTimer {
    pub async fn sleep_for(mut self, mut duration_in_ms: f64) {
        loop {
            let _r = self.tick_recv.changed().await;
            if _r.is_err() {
                // This means that the executor supplying the delta channel has shutdown
                // We must stop waiting gracefully
                break;
            }
            let current_dt = *self.tick_recv.borrow_and_update();
            duration_in_ms -= current_dt;
            if duration_in_ms <= 0.0 {
                break;
            }
        }
    }
}