[−][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>ⓘ
Important traits for StreamSink<A, B>
impl<A, B> Future for StreamSink<A, B> where
    A: Stream,
    B: Sink<A::Item>,     type Output = B::Done;

    where
        S: Sink<Self::Item>,
        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>ⓘ

Important traits for StreamSink<A, B>

impl<A, B> Future for StreamSink<A, B> where
    A: Stream,
    B: Sink<A::Item>,  type Output = B::Done;
 where
    S: Sink<Self::Item>,
    Self: Sized, 

Loading content...

Implementors

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

Loading content...