Struct Fanout 

pub struct Fanout<Push0, Push1> { /* private fields */ }

Push combinator that clones each item and pushes to both downstream pushes.

This is the push equivalent of futures::sink::SinkExt::fanout.

Trait Implementations

impl<Push0: Clone, Push1: Clone> Clone for Fanout<Push0, Push1>

fn clone(&self) -> Fanout<Push0, Push1>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Push0: Debug, Push1: Debug> Debug for Fanout<Push0, Push1>

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

Formats the value using the given formatter.

impl<P0, P1, Item, Meta> Push<Item, Meta> for Fanout<P0, P1>

where P0: Push<Item, Meta>, P1: Push<Item, Meta>, Item: Clone, Meta: Copy,

type Ctx<'ctx> = <<P0 as Push<Item, Meta>>::Ctx<'ctx> as Context<'ctx>>::Merged<<P1 as Push<Item, Meta>>::Ctx<'ctx>>

The context type required to push into this pipeline.

type CanPend = <<P0 as Push<Item, Meta>>::CanPend as Toggle>::Or<<P1 as Push<Item, Meta>>::CanPend>

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, Push0, Push1> Unpin for Fanout<Push0, Push1>

where PinnedFieldsOf<__Origin<'__pin, Push0, Push1>>: Unpin,