Enum amadeus::par_sink::ResultReducerAsync

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

Variants

Ok(R)

Err(Option<E>)

Trait Implementations

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

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

fn poll_forward(
    self: Pin<&mut ResultReducerAsync<R, E>>,
    cx: &mut Context,
    stream: Pin<&mut impl Stream<Item = Result<Item, E>>>
) -> Poll<<ResultReducerAsync<R, E> as Sink<Result<Item, E>>>::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<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>