Struct SinkBuilder 

pub struct SinkBuilder<Item>(/* private fields */);

Start a SinkBuild adaptor chain, with Item as the input item type.

Implementations

impl<Item> SinkBuilder<Item>

pub fn new() -> Self

Create a new sink builder.

Trait Implementations

impl<Item> Default for SinkBuilder<Item>

fn default() -> Self

Returns the “default value” for a type.

impl<Item> SinkBuild for SinkBuilder<Item>

type Item = Item

The output item type.

type Output<Next: Sink<Self::Item>> = Next

The output Sink type, if it is prepended to Next.

fn send_to<Next>(self, next: Next) -> Self::Output<Next>

where Next: Sink<Self::Item>,

Complete this sink adaptor chain by connecting it to next as the output.

fn fanout<Si0, Si1>( self, sink0: Si0, sink1: Si1, ) -> Self::Output<Fanout<Si0, Si1>>

where Self: Sized, Self::Item: Clone, Si0: Sink<Self::Item>, Si1: Sink<Self::Item, Error = Si0::Error>,

Clone each item and send to both sink0 and sink1, completing this sink adaptor chain.

fn for_each<Func>(self, func: Func) -> Self::Output<ForEach<Func>>

where Self: Sized, Func: FnMut(Self::Item),

Appends a function which consumes each element, completing this sink adaptor chain.

fn try_for_each<Func, Error>(self, func: Func) -> Self::Output<TryForEach<Func>>

where Self: Sized, Func: FnMut(Self::Item) -> Result<(), Error>,

Appends a function which consumes each element and returns a result, completing this sink adaptor chain.

fn map<Func, Out>(self, func: Func) -> MapBuilder<Self, Func>

where Self: Sized, Func: FnMut(Self::Item) -> Out,

Appends a function which is called on each element and pases along each output.

fn filter<Func>(self, func: Func) -> FilterBuilder<Self, Func>

where Self: Sized, Func: FnMut(&Self::Item) -> bool,

Appends a predicate function which filters items.

fn filter_map<Func, Out>(self, func: Func) -> FilterMapBuilder<Self, Func>

where Self: Sized, Func: FnMut(Self::Item) -> Option<Out>,

Appends a function which both filters and maps items.

fn flat_map<Func, IntoIter>(self, func: Func) -> FlatMapBuilder<Self, Func>

where Self: Sized, Func: FnMut(Self::Item) -> IntoIter, IntoIter: IntoIterator,

Appends a function which maps each item to an iterator and flattens the results.

fn flatten<IntoIter>(self) -> FlattenBuilder<Self>

where Self: Sized, Self::Item: IntoIterator,

Flattens items that are iterators.

fn inspect<Func>(self, func: Func) -> InspectBuilder<Self, Func>

where Self: Sized, Func: FnMut(&Self::Item),

Appends a function which inspects each item without modifying it.

fn unzip<Si0, Si1, Item0, Item1>( self, sink0: Si0, sink1: Si1, ) -> Self::Output<Unzip<Si0, Si1>>

where Self: Sized + SinkBuild<Item = (Item0, Item1)>, Si0: Sink<Item0>, Si1: Sink<Item1>, Si0::Error: From<Si1::Error>,

Splits items into two sinks based on tuple structure.

fn demux_map<Key, ItemVal, Si>( self, sinks: impl Into<HashMap<Key, Si>>, ) -> Self::Output<DemuxMap<Key, Si>>

where Self: Sized + SinkBuild<Item = (Key, ItemVal)>, Key: Eq + Hash + Debug + Unpin, Si: Sink<ItemVal> + Unpin,

Available on crate feature std only.

Sends each item into one sink depending on the key, where the sinks are in a HashMap.

fn demux_var<Sinks, ItemVal, Error>( self, sinks: Sinks, ) -> Self::Output<DemuxVar<Sinks, Error>>

where Self: Sized + SinkBuild<Item = (usize, ItemVal)>, Sinks: SinkVariadic<ItemVal, Error>,

Available on crate feature variadics only.

Sends each item into one sink depending on the index, where the sinks are a variadic.