pi-async-rt 0.3.1

Based on future (MVP), a universal asynchronous runtime and tool used to provide a foundation for the outside world
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
33
34
35
36
37
38
39

use futures::Future;
use pi_async_rt::{prelude::SingleTaskRunner, rt::AsyncRuntimeExt};
use std::{thread::sleep, time::Duration};

/// Runs the provided future, blocking the current thread until the
/// future completes.
///
pub fn block_on<F>(future: F) -> F::Output
where
    F: Future + Send + 'static,
    <F as Future>::Output: Default + Send + 'static,
{
    let runner = SingleTaskRunner::<()>::default();
    let rt = runner.startup().unwrap();
    rt.block_on(future).unwrap()
}

#[test]
fn async_block() {
    assert_eq!(4, block_on(async { 4 }));
}

async fn five() -> u8 {
    5
}

#[test]
fn async_fn() {
    assert_eq!(5, block_on(five()));
}

#[test]
fn test_sleep() {
    let deadline = Duration::from_millis(100);

    block_on(async move {
        sleep(deadline);
    });
}