Struct amadeus_core::par_sink::IntoReducerAsync

pub struct IntoReducerAsync<R, T>(_, _);

Trait Implementations

impl<R, T> PinnedDrop for IntoReducerAsync<R, T>

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

impl<R: Sink<Item>, T, Item> Sink<Item> for IntoReducerAsync<R, T> where
    R::Done: Into<T>, 

type Done = T

fn poll_forward(
    self: Pin<&mut Self>,
    cx: &mut Context,
    stream: Pin<&mut impl Stream<Item = Item>>
) -> 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>ⓘ

Important 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, 

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

Important 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, 

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

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

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

where
    Self: Unpin, 

impl<'pin, R, T> Unpin for IntoReducerAsync<R, T> where
    __IntoReducerAsync<'pin, R, T>: Unpin, 

impl<R, T> UnsafeUnpin for IntoReducerAsync<R, T>