par-stream 0.10.2

Asynchronous parallel streams analogous to rayon
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

// macro_rules! has_rt {
//     ($($item:item)*) => {
//         $(
//             crate::utils::has_tokio! {
//                 $item
//             }

//             crate::utils::has_async_std! {
//                 $item
//             }
//         )*
//     };
// }
// pub(crate) use has_rt;

macro_rules! no_rt {
    ($($item:item)*) => {
        $(
            #[cfg(all(not(feature = "runtime-async-std"), not(feature = "runtime-tokio"),))]
            $item
        )*
    };
}
pub(crate) use no_rt;

macro_rules! has_tokio {
    ($($item:item)*) => {
        $(
            #[cfg(all(not(feature = "runtime-async-std"), feature = "runtime-tokio",))]
            $item
        )*
    };
}
pub(crate) use has_tokio;

macro_rules! has_async_std {
    ($($item:item)*) => {
        $(
            #[cfg(all(feature = "runtime-async-std", not(feature = "runtime-tokio"),))]
            $item
        )*
    };
}
pub(crate) use has_async_std;

#[allow(unused_macros)]
macro_rules! async_test {
    ($($item:item)*) => {
        crate::utils::has_tokio! {
            $(
                #[tokio::test]
                $item
            )*
        }

        crate::utils::has_async_std! {
            $(
                #[async_std::test]
                $item
            )*
        }
    };
}
#[allow(unused_imports)]
pub(crate) use async_test;

pub fn channel<T>(capacity: impl Into<Option<usize>>) -> (flume::Sender<T>, flume::Receiver<T>) {
    match capacity.into() {
        Some(capacity) => flume::bounded(capacity),
        None => flume::unbounded(),
    }
}