streem 0.3.0

Simple utilities for creating and consuming streams
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

use streem::IntoStreamer;

fn main() -> Result<(), &'static str> {
    futures_executor::block_on(async {
        let input_stream = std::pin::pin!(streem::from_fn(|yielder| async move {
            for item in [Ok(1), Ok(2), Err("failure")] {
                yielder.yield_(item).await;
            }
        }));

        let mut input_streamer = input_stream.into_streamer();

        let output_stream = std::pin::pin!(streem::try_from_fn(|yielder| async move {
            while let Some(item) = input_streamer.try_next().await? {
                yielder.yield_ok(item).await;
            }

            Ok(())
        }));

        let mut output_streamer = output_stream.into_streamer();

        while let Some(item) = output_streamer.try_next().await? {
            println!("Got {item}");
        }

        Ok(())
    })
}