Struct ResolveFutures 

pub struct ResolveFutures<Psh, Queue, QueueInner> { /* private fields */ }

Push operator that receives futures, queues them, and pushes their resolved outputs downstream.

Queue is expected to be either [futures_util::stream::FuturesOrdered] or [futures_util::stream::FuturesUnordered] (or a mutable reference thereof).

Trait Implementations

impl<Psh, Queue, QueueInner, Fut> Push<Fut, ()> for ResolveFutures<Psh, Queue, QueueInner>

where Psh: Push<Fut::Output, ()>, Queue: BorrowMut<QueueInner>, QueueInner: Extend<Fut> + FusedStream<Item = Fut::Output> + Unpin, Fut: Future, for<'ctx> Psh::Ctx<'ctx>: Context<'ctx>,

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: Fut, _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, Psh, Queue, QueueInner> Unpin for ResolveFutures<Psh, Queue, QueueInner>

where PinnedFieldsOf<__Origin<'__pin, Psh, Queue, QueueInner>>: Unpin,