polyoxide-rt 0.48.0

The runtime seam the polyoxide crates share: an injected clock, sleep and spawn, with the tasks, timeouts and intervals built on them
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

//! `TokioRuntime`, the native runtime.

use std::time::Duration;

use crate::{BoxFuture, Instant, Runtime};

/// The runtime over tokio's spawn, sleep, yield and clock.
///
/// It reads tokio's clock, so a test on `tokio::time::pause` (or
/// `#[tokio::test(start_paused = true)]`) drives it. `spawn` panics outside a
/// tokio runtime, as `tokio::spawn` does.
#[derive(Debug, Clone, Copy, Default)]
pub struct TokioRuntime;

impl Runtime for TokioRuntime {
    fn spawn(&self, task: BoxFuture<()>) {
        ::tokio::spawn(task);
    }

    fn sleep(&self, duration: Duration) -> BoxFuture<()> {
        Box::pin(::tokio::time::sleep(duration))
    }

    fn yield_now(&self) -> BoxFuture<()> {
        Box::pin(::tokio::task::yield_now())
    }

    fn now(&self) -> Instant {
        ::tokio::time::Instant::now().into_std()
    }
}