rx-rust 0.3.0

Reactive Programming in Rust inspired by ReactiveX https://reactivex.io/
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

use crate::tests_utils::test_runtime::{TestRuntime, block_on};
use rx_rust::utils::types::NecessarySendSync;

pub(crate) fn stress_test<FU>(
    test: impl FnOnce(TestRuntime, usize) -> FU + Clone + NecessarySendSync + 'static,
) where
    FU: Future<Output = ()> + NecessarySendSync + 'static,
{
    block_on(|runtime| async move {
        const COUNT: usize = 100000;
        let mut handles = Vec::with_capacity(COUNT);
        for i in 0..COUNT {
            let test = test.clone();
            let runtime_cloned = runtime.clone();
            let handle = runtime.spawn(async move {
                test(runtime_cloned, i).await;
            });
            handles.push(handle);
        }
        for handle in handles {
            handle.await.unwrap();
        }
    });
}