Struct ReduceC3Async 

pub struct ReduceC3Async<A, B, C, S0, S1, S2>
where
    A: Sink<S0>,
    B: Sink<S1>,
    C: Sink<S2>,
{ /* private fields */ }

Trait Implementations

impl<A: Sink<S0>, B: Sink<S1>, C: Sink<S2>, S0, S1, S2> Sink<(S0, S1, S2)> for ReduceC3Async<A, B, C, S0, S1, S2>

type Done = (<A as Sink<S0>>::Done, <B as Sink<S1>>::Done, <C as Sink<S2>>::Done)

fn poll_forward( self: Pin<&mut Self>, cx: &mut Context<'_>, stream: Pin<&mut impl Stream<Item = (S0, S1, S2)>>, ) -> 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, A, B, C, S0, S1, S2> Unpin for ReduceC3Async<A, B, C, S0, S1, S2>

where A: Sink<S0>, B: Sink<S1>, C: Sink<S2>, __ReduceC3Async<'pin, A, B, C, S0, S1, S2>: Unpin,

impl<A, B, C, S0, S1, S2> UnsafeUnpin for ReduceC3Async<A, B, C, S0, S1, S2>

where A: Sink<S0>, B: Sink<S1>, C: Sink<S2>,