ticked_async_executor 0.3.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
22
23
24
25
26
27

use std::sync::mpsc;

pub struct TickedTimerFromTimerRegistration {
    timer_registration_tx: mpsc::Sender<(f64, tokio::sync::oneshot::Sender<()>)>,
}

impl TickedTimerFromTimerRegistration {
    pub fn new(
        timer_registration_tx: mpsc::Sender<(f64, tokio::sync::oneshot::Sender<()>)>,
    ) -> Self {
        Self {
            timer_registration_tx,
        }
    }

    pub async fn sleep_for(&self, duration_in_ms: f64) {
        let (tx, rx) = tokio::sync::oneshot::channel();
        let _ignore = async {
            self.timer_registration_tx
                .send((duration_in_ms, tx))
                .map_err(|_| ())?;
            rx.await.map_err(|_| ())?;
            Ok::<(), ()>(())
        }
        .await;
    }
}