Trait IntoStream 

pub trait IntoStream<T> {
    // Required method
    fn into_stream(self) -> Rc<dyn Stream<T>>;
}

Used to consume a concrete Stream and return an Rc<dyn Stream>>.

Required Methods

fn into_stream(self) -> Rc<dyn Stream<T>>

Implementors

impl<T, STREAM> IntoStream<T> for STREAM

where T: Clone + 'static, STREAM: StreamPeekRef<T> + 'static,