streamunordered 0.5.5

An efficient async stream multiplexer
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

use std::{future::ready, pin::pin};

use futures_util::stream;
use streamunordered::StreamUnordered;

#[test]
fn iter_methods() {
    let mut streams = StreamUnordered::new();
    for i in 0..5 {
        streams.insert(stream::once(ready(i)));
    }

    let mut result: (Vec<_>, Vec<_>) = streams.iter_with_token().unzip();
    result.1.sort(); // We sort as order is not guaranteed.
    assert_eq!(result.1, vec![1, 2, 3, 4, 5]);

    assert_eq!(streams.iter_mut().len(), 5);

    let mut result: (Vec<_>, Vec<_>) = streams.iter_mut_with_token().unzip();
    result.1.sort(); // We sort as order is not guaranteed.
    assert_eq!(result.1, vec![1, 2, 3, 4, 5]);

    let mut streams = pin!(streams);

    assert_eq!(streams.as_mut().iter_pin_mut().len(), 5);

    let mut result: (Vec<_>, Vec<_>) = streams.iter_pin_mut_with_token().unzip();
    result.1.sort(); // We sort as order is not guaranteed.
    assert_eq!(result.1, vec![1, 2, 3, 4, 5]);
}