obeli-sk-wasm-workers 0.2.1

Internal package of obeli-sk
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 std::time::Duration;

use tokio::task::AbortHandle;
use wasmtime::EngineWeak;

pub struct EpochTicker {
    abort_handle: AbortHandle,
}

impl EpochTicker {
    #[must_use]
    pub fn spawn_new(engines: Vec<EngineWeak>, epoch: Duration) -> Self {
        let abort_handle = tokio::spawn(async move {
            loop {
                tokio::time::sleep(epoch).await;
                for engine in &engines {
                    if let Some(engine) = engine.upgrade() {
                        engine.increment_epoch();
                    }
                }
            }
        })
        .abort_handle();
        Self { abort_handle }
    }
}

impl Drop for EpochTicker {
    fn drop(&mut self) {
        self.abort_handle.abort();
    }
}