Struct Sink 

pub struct Sink<Si> { /* private fields */ }

Adapter that wraps a futures_sink::Sink to implement the Push trait.

Since Sink is asynchronous, this push requires core::task::Context and can return Pending.

Trait Implementations

impl<Si, Item, Meta> Push<Item, Meta> for Sink<Si>

where Si: Sink<Item>, Si::Error: Debug, Meta: Copy,

type Ctx<'ctx> = Context<'ctx>

The context type required to push into this pipeline.

type CanPend = Yes

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, Si> Unpin for Sink<Si>

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