Enum amadeus_core::par_sink::ResultReducerAsync[−][src]

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

Variants

Ok(R)
Err(Option<E>)

Trait Implementations

impl<R, E> PinnedDrop for ResultReducerAsync<R, E>[src]

unsafe fn drop(self: Pin<&mut Self>)[src]

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

type Done = Result<R::Done, E>

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

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). Read more

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

Notable traits for Send<'_, S, Item>

impl<S: ?Sized + Sink<Item> + Unpin, Item> Future for Send<'_, S, Item> type Output = Option<S::Done>;
 where
    Self: Unpin, [src]

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

Notable traits for SendAll<'_, S, St>

impl<S: ?Sized + Sink<Item> + Unpin, St: ?Sized + Stream<Item = Item> + Unpin, Item> Future for SendAll<'_, S, St> type Output = Option<S::Done>;
 where
    S: Stream<Item = Item> + Unpin,
    Self: Unpin, [src]

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

Notable traits for Done<'_, S, Item>

impl<S: ?Sized + Sink<Item> + Unpin, Item> Future for Done<'_, S, Item> type Output = S::Done;
 where
    Self: Unpin, [src]

impl<'pin, R, E> Unpin for ResultReducerAsync<R, E> where
    __ResultReducerAsync<'pin, R, E>: Unpin, [src]

impl<R, E> UnsafeUnpin for ResultReducerAsync<R, E>[src]

Auto Trait Implementations

impl<R, E> RefUnwindSafe for ResultReducerAsync<R, E> where
    E: RefUnwindSafe,
    R: RefUnwindSafe, 

impl<R, E> Send for ResultReducerAsync<R, E> where
    E: Send,
    R: Send, 

impl<R, E> Sync for ResultReducerAsync<R, E> where
    E: Sync,
    R: Sync, 

impl<R, E> UnwindSafe for ResultReducerAsync<R, E> where
    E: UnwindSafe,
    R: UnwindSafe, 

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src]

pub fn type_id(&self) -> TypeId[src]

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T where
    T: ?Sized, [src]

pub fn borrow(&self) -> &T[src]

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src]

pub fn borrow_mut(&mut self) -> &mut T[src]

Mutably borrows from an owned value. Read more

impl<T> From<T> for T[src]

pub fn from(t: T) -> T[src]

Performs the conversion.

impl<T, U> Into<U> for T where
    U: From<T>, [src]

pub fn into(self) -> U[src]

Performs the conversion.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src]

type Error = Infallible

The type returned in the event of a conversion error.

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]

Performs the conversion.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]

Performs the conversion.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, 

pub fn vzip(self) -> V