Struct amadeus_core::pipe::PipePipe[−][src]

pub struct PipePipe<A, B> { /* fields omitted */ }

Trait Implementations

impl<A, B> PinnedDrop for PipePipe<A, B>[src]

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

impl<A, B, Input> Pipe<Input> for PipePipe<A, B> where
    A: Pipe<Input>,
    B: Pipe<A::Output>, [src]

type Output = B::Output

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

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

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

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

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

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

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

impl<'pin, A, B> Unpin for PipePipe<A, B> where
    __PipePipe<'pin, A, B>: Unpin, [src]

impl<A, B> UnsafeUnpin for PipePipe<A, B>[src]

Auto Trait Implementations

impl<A, B> RefUnwindSafe for PipePipe<A, B> where
    A: RefUnwindSafe,
    B: RefUnwindSafe, 

impl<A, B> Send for PipePipe<A, B> where
    A: Send,
    B: Send, 

impl<A, B> Sync for PipePipe<A, B> where
    A: Sync,
    B: Sync, 

impl<A, B> UnwindSafe for PipePipe<A, B> where
    A: UnwindSafe,
    B: 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