asynkit 0.1.0

Abstractions for runtime-independent crates
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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96

pub mod runtime;
pub mod tcp;
pub mod time;

macro_rules! test {
    ($runtime:ty, $threads:literal, $module:ident :: $test:ident) => {
        #[test]
        fn $test() {
            <$runtime>::new($threads).block_on($crate::$module::$test::<$runtime>());
        }
    };
}

macro_rules! test_panic {
    ($runtime:ty, $threads:literal, $module:ident :: $test:ident) => {
        #[test]
        #[should_panic]
        fn $test() {
            <$runtime>::new($threads).block_on($crate::$module::$test::<$runtime>());
        }
    };
}

#[macro_export]
macro_rules! test_suite {
    ($name:ident, $runtime:ty) => {
        mod $name {
            mod runtime {
                use runtime::Runtime;

                test!(
                    $runtime,
                    1,
                    runtime::block_on_returns_completed_future_value
                );
                test!($runtime, 1, runtime::defer_spawn_returns_joined_task_result);
                test!(
                    $runtime,
                    1,
                    runtime::defer_join_returns_deferred_future_output
                );
                test!(
                    $runtime,
                    1,
                    runtime::defer_spawn_after_runtime_dropped_returns_disconnected
                );
                test_panic!(
                    $runtime,
                    2,
                    runtime::spawn_local_panics_on_multi_threaded_runtime
                );
                test!(
                    $runtime,
                    1,
                    runtime::spawn_local_returns_result_on_single_threaded_runtime
                );
            }

            mod tcp {
                use runtime::Runtime;

                test!($runtime, 1, tcp::listener_bind_succeeds_on_localhost);
                test!($runtime, 1, tcp::stream_connect_succeeds_to_bound_listener);
                test!($runtime, 1, tcp::stream_read_write_round_trip_succeeds);
            }

            mod time {
                use runtime::Runtime;

                test!(
                    $runtime,
                    1,
                    time::sleep_delays_for_at_least_requested_duration
                );
                test!(
                    $runtime,
                    1,
                    time::timeout_returns_ok_when_future_completes_in_time
                );
                test!(
                    $runtime,
                    1,
                    time::timeout_returns_timed_out_when_future_exceeds_limit
                );
                test!(
                    $runtime,
                    1,
                    time::timeout_with_zero_duration_returns_immediate_future
                );
            }
        }
    };
}

#[cfg(feature = "tokio")]
test_suite!(tokio, ::runtime::tokio::Tokio);