[−][src]Trait amadeus_core::pipe::StreamExt

pub trait StreamExt: Stream {
    fn pipe<P>(self, pipe: P) -> StreamPipe<Self, P>
    where
        P: Pipe<Self::Item>,
        Self: Sized,
    { ... }

    fn sink<S>(self, sink: S) -> StreamSink<Self, S>
    where
        S: Sink<Self::Item>,
        Self: Sized,
    { ... }

    fn flat_map<F, R>(self, f: F) -> FlatMap<Self, F, R>
    where
        F: FnMut(Self::Item) -> R,
        R: Stream,
        Self: Sized,
    { ... }

    fn filter<F>(self, f: F) -> Filter<Self, F>
    where
        F: FnMut(&Self::Item) -> bool,
        Self: Sized,
    { ... }
}

Provided methods

fn pipe<P>(self, pipe: P) -> StreamPipe<Self, P> where
    P: Pipe<Self::Item>,
    Self: Sized, 

fn sink<S>(self, sink: S) -> StreamSink<Self, S> where
    S: Sink<Self::Item>,
    Self: Sized, 

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

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

Loading content...

Implementors

impl<S: ?Sized> StreamExt for S where
    S: Stream, [src]

Loading content...