Struct FlatMapBuilder

pub struct FlatMapBuilder<'t, T, C: DrainContainer, F, I>
where
    for<'a> F: Fn(C::Item<'a>) -> I + 'static,
{ /* private fields */ }

A stream wrapper that allows the accumulation of flatmap logic.

Implementations

impl<'t, T, C: DrainContainer + Clone + 'static, F, I> FlatMapBuilder<'t, T, C, F, I>

where for<'a> F: Fn(C::Item<'a>) -> I,

pub fn new(stream: &'t T, logic: F) -> Self

Create a new wrapper with no action on the stream.

pub fn map<G: Fn(I) -> I2 + 'static, I2>( self, g: G, ) -> FlatMapBuilder<'t, T, C, impl Fn(C::Item<'_>) -> I2 + 'static, I2>

Transform a flatmapped stream through addiitonal logic.

pub fn into_stream<S, C2>(self) -> StreamCore<S, C2>

where I: IntoIterator, S: Scope, T: Map<S, C>, C2: Container + SizableContainer + PushInto<I::Item>,

Convert the wrapper into a stream.