Trait StreamLayerExt 

pub trait StreamLayerExt<T>: Stream<Item = T> + Sized
where
    T: 'static,
{
    // Provided method
    fn layer<P>(self, processor: P) -> ProcessorStream<P, Self, T>
       where P: Processor<T> + 'static { ... }
}

Extension trait for Stream that provides convenient methods to layer up processors.

Provided Methods

fn layer<P>(self, processor: P) -> ProcessorStream<P, Self, T>

where P: Processor<T> + 'static,

Processes this stream through the provided layer.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<S, T: 'static> StreamLayerExt<T> for S

where S: Stream<Item = T>,