[−][src]Trait amadeus_core::pipe::StreamExt
Provided methods
fn pipe<P>(self, pipe: P) -> StreamPipe<Self, P> where
P: Pipe<Self::Item>,
Self: Sized,
P: Pipe<Self::Item>,
Self: Sized,
fn sink<S>(self, sink: S) -> StreamSink<Self, S>ⓘImportant traits for StreamSink<A, B>
impl<A, B> Future for StreamSink<A, B> where
A: Stream,
B: Sink<A::Item>, type Output = ();
where
S: Sink<Self::Item>,
Self: Sized,
Important traits for StreamSink<A, B>
impl<A, B> Future for StreamSink<A, B> where
A: Stream,
B: Sink<A::Item>, type Output = ();
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,
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,
F: FnMut(&Self::Item) -> bool,
Self: Sized,