switchyard 0.3.1

Real-time compute focused async executor
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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

use switchyard::{threads::single_thread, Switchyard};

#[test]
#[should_panic]
fn panicking_future() {
    let yard = Switchyard::new(single_thread(None, None), || ()).unwrap();

    let handle = yard.spawn(0, async move {
        panic!("whoops!");
    });

    futures_executor::block_on(handle);
}

#[test]
#[should_panic]
fn panicking_function() {
    let yard = Switchyard::new(single_thread(None, None), || ()).unwrap();

    let handle = yard.spawn_local(0, |_| {
        panic!("whoops!");
        #[allow(unreachable_code)]
        async move {}
    });

    futures_executor::block_on(handle);
}

#[test]
#[should_panic]
fn panicking_local_future() {
    let yard = Switchyard::new(single_thread(None, None), || ()).unwrap();

    let handle = yard.spawn_local(0, |_| async move { panic!("whoops!") });

    futures_executor::block_on(handle);
}

#[test]
fn continue_from_panicking_future() {
    let yard = Switchyard::new(single_thread(None, None), || ()).unwrap();

    // ignore handle, it'll panic
    yard.spawn(0, async move {
        panic!("whoops!");
    });

    futures_executor::block_on(yard.wait_for_idle());

    let handle = yard.spawn(0, async move { 1 });

    assert_eq!(futures_executor::block_on(handle), 1);
}