rs2-stream 0.3.3

A high-performance, production-ready async streaming library for Rust.
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

use futures_util::stream::StreamExt;
use rs2_stream::pipe::*;
use rs2_stream::rs2::*;
use tokio::runtime::Runtime;

fn main() {
    let rt = Runtime::new().unwrap();
    rt.block_on(async {
        // Create a stream of numbers
        let numbers = from_iter(vec![1, 2, 3, 4, 5, 6]);

        // Create pipes for different transformations
        let even_filter = filter(|&x: &i32| x % 2 == 0);
        let double_map = map(|x: i32| x * 2);

        // Compose the pipes using the compose function
        let even_then_double = compose(even_filter, double_map);

        // Apply the composed pipe to the stream
        let result_stream = even_then_double.apply(numbers);

        // Collect the results
        let result = result_stream.collect::<Vec<_>>().await;
        println!("Even numbers doubled: {:?}", result); // [4, 8, 12]

        // Alternatively, use the compose method on the Pipe
        let numbers = from_iter(vec![1, 2, 3, 4, 5, 6]);
        let even_filter = filter(|&x: &i32| x % 2 == 0);
        let double_map = map(|x: i32| x * 2);

        // Use the compose method
        let even_then_double = even_filter.compose(double_map);

        // Apply the composed pipe to the stream
        let result_stream = even_then_double.apply(numbers);

        // Collect the results
        let result = result_stream.collect::<Vec<_>>().await;
        println!("Even numbers doubled (using compose method): {:?}", result); // [4, 8, 12]
    });
}