Enum ResultReducerAsync 

pub enum ResultReducerAsync<R, E> {
    Ok(R),
    Err(Option<E>),
}

Variants

Ok(R)

Err(Option<E>)

Trait Implementations

impl<R: Sink<Item>, E, Item> Sink<Result<Item, E>> for ResultReducerAsync<R, E>

type Done = Result<<R as Sink<Item>>::Done, E>

fn poll_forward( self: Pin<&mut Self>, cx: &mut Context<'_>, stream: Pin<&mut impl Stream<Item = Result<Item, E>>>, ) -> Poll<Self::Done>

Returns Poll::Ready when a) it can’t accept any more elements from stream and b) all accepted elements have been fully processed. By convention, stream yielding None typically triggers (a).

fn send(&mut self, item: Item) -> Send<'_, Self, Item>

where Self: Unpin,

fn send_all<'a, S>(&'a mut self, items: &'a mut S) -> SendAll<'a, Self, S>

where S: Stream<Item = Item> + Unpin + ?Sized, Self: Unpin,

fn done(&mut self) -> Done<'_, Self, Item>

where Self: Unpin,

impl<'pin, R, E> Unpin for ResultReducerAsync<R, E>

where __ResultReducerAsync<'pin, R, E>: Unpin,

impl<R, E> UnsafeUnpin for ResultReducerAsync<R, E>