aither-core 0.14.0

Core trait abstractions for aither
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

//! A runtime-agnostic timer.

use core::time::Duration;

/// Completes once `duration` has passed.
///
/// Native targets park on `async-io`'s reactor. wasm32 has no reactor, and the
/// browser timer is not `Send` while the futures built on this one must be, so
/// the timer runs on the JS event loop and is awaited through a channel.
pub async fn sleep(duration: Duration) {
    #[cfg(not(target_arch = "wasm32"))]
    async_io::Timer::after(duration).await;

    #[cfg(target_arch = "wasm32")]
    {
        let millis = u32::try_from(duration.as_millis()).unwrap_or(u32::MAX);
        let (elapsed_tx, elapsed_rx) = async_channel::bounded::<()>(1);
        wasm_bindgen_futures::spawn_local(async move {
            gloo_timers::future::TimeoutFuture::new(millis).await;
            let _ = elapsed_tx.send(()).await;
        });
        // A closed channel means the timer task was dropped, which only
        // happens while the whole future is being torn down.
        let _ = elapsed_rx.recv().await;
    }
}