Struct amadeus_core::par_sink::AsyncTuple8

pub struct AsyncTuple8<Input, C0, C1, C2, C3, C4, C5, C6, C7> { /* fields omitted */ }

Trait Implementations

impl<Input, C0, C1, C2, C3, C4, C5, C6, C7> PinnedDrop for AsyncTuple8<Input, C0, C1, C2, C3, C4, C5, C6, C7>

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

impl<Input, C0: Pipe<Input>, C1: Pipe<Input>, C2: Pipe<Input>, C3: Pipe<Input>, C4: Pipe<Input>, C5: Pipe<Input>, C6: Pipe<Input>, C7: Pipe<Input>> Pipe<Input> for AsyncTuple8<Input, C0, C1, C2, C3, C4, C5, C6, C7> where
    Input: Copy, 

type Output = Sum8<C0::Output, C1::Output, C2::Output, C3::Output, C4::Output, C5::Output, C6::Output, C7::Output>

fn poll_next(
    self: Pin<&mut Self>,
    cx: &mut Context,
    stream: Pin<&mut impl Stream<Item = Input>>
) -> Poll<Option<Self::Output>>

fn pipe<P>(self, pipe: P) -> PipePipe<Self, P> where
    P: Pipe<Self::Output>,
    Self: Sized, 

fn sink<S>(self, sink: S) -> PipeSink<Self, S> where
    S: Sink<Self::Output>,
    Self: Sized, 

fn filter<F>(self, f: F) -> Filter<Self, F> where
    F: FnMut(&Self::Output) -> bool,
    Self: Sized, 

fn flat_map<F, R>(self, f: F) -> FlatMap<Self, F, R> where
    F: FnMut(Self::Output) -> R,
    R: Stream,
    Self: Sized, 

fn flatten(self) -> Flatten<Self, Self::Output> where
    Self::Output: Stream,
    Self: Sized, 

fn map<F, R>(self, f: F) -> Map<Self, F> where
    F: FnMut(Self::Output) -> R,
    Self: Sized, 

impl<'pin, Input, C0, C1, C2, C3, C4, C5, C6, C7> Unpin for AsyncTuple8<Input, C0, C1, C2, C3, C4, C5, C6, C7> where
    __AsyncTuple8<'pin, Input, C0, C1, C2, C3, C4, C5, C6, C7>: Unpin, 

impl<Input, C0, C1, C2, C3, C4, C5, C6, C7> UnsafeUnpin for AsyncTuple8<Input, C0, C1, C2, C3, C4, C5, C6, C7>