Struct ForEach 

pub struct ForEach<Func> { /* private fields */ }

Terminal push combinator that consumes each item with a closure.

This is the push equivalent of the pull-side ForEach future. It has no downstream push; items are consumed by func.

Trait Implementations

impl<Func: Clone> Clone for ForEach<Func>

fn clone(&self) -> ForEach<Func>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Func: Debug> Debug for ForEach<Func>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Func, Item, Meta> Push<Item, Meta> for ForEach<Func>

where Func: FnMut(Item), Meta: Copy,

type Ctx<'ctx> = ()

The context type required to push into this pipeline.

type CanPend = Infallible

Whether this push can return PushStep::Pending.

fn poll_ready( self: Pin<&mut Self>, _ctx: &mut Self::Ctx<'_>, ) -> PushStep<Self::CanPend>

Check if this push is ready to accept an item.

fn start_send(self: Pin<&mut Self>, item: Item, _meta: Meta)

Send an item into this push pipeline.

fn poll_flush( self: Pin<&mut Self>, _ctx: &mut Self::Ctx<'_>, ) -> PushStep<Self::CanPend>

Flushes any buffered items in this push pipeline.

fn size_hint(self: Pin<&mut Self>, _hint: (usize, Option<usize>))

Informs this push how many items are about to be sent.

impl<'__pin, Func> Unpin for ForEach<Func>

where PinnedFieldsOf<__Origin<'__pin, Func>>: Unpin,