Struct TryReduceAsync 

pub struct TryReduceAsync<B, F, R>
where
    B: BufferableBulk,
    F: FnMut<(B::Item, B::Item), Output: Future<Output = R>>,
    R: Try<Output = B::Item, Residual: Residual<Option<B::Item>>>,
{ /* private fields */ }

Trait Implementations

impl<B, F, R> Future for TryReduceAsync<B, F, R>

where B: BufferableBulk, F: FnMut<(B::Item, B::Item), Output: Future<Output = R>>, R: Try<Output = B::Item, Residual: Residual<Option<B::Item>>>,

type Output = <<R as Try>::Residual as Residual<Option<<B as IntoIterator>::Item>>>::TryType

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.