Filter example

[marcelbuesing]

How would a filter example look like, e.g. taking the example from the README yielding only odd numbers based on a source stream?

fn zero_to_three() -> impl Stream<Item = u32> {
    stream! {
        for i in 0..3 {
            yield i;
        }
    }
}

/// Stream of only odd numbers
fn odds<S: Stream<Item = u32>>(input: S)
    -> impl Stream<Item = u32>
{
    stream! {
        pin_mut!(input);
        while let Some(value) = input.next().await {
            // ???
        }
    }
}

[taiki-e]

I recommend using futures::stream::StreamExt::filter/tokio::stream::StreamExt::filter + for await.

fn f<S: Stream<Item = u32>>(input: S)
    -> impl Stream<Item = u32>
{
    stream! {
        for await value in input.filter(|v| v % 2 !=0) {
            // ...
        }
    }
}