Trait PipeExt 

pub trait PipeExt<B, Args, Ctx>
where
    Self: Sized,
{
    // Required method
    fn pipe_to(self, backend: B) -> Pipe<Self, B, Args, Ctx>;
}

Represents utility for piping streams into a backend

Required Methods

fn pipe_to(self, backend: B) -> Pipe<Self, B, Args, Ctx>

Pipe the current stream into the provided backend

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<B, Args, Ctx, Err, S> PipeExt<B, Args, Ctx> for S

where S: Stream<Item = Result<Args, Err>> + Send + 'static, <B as Backend>::Error: Into<BoxDynError> + Send + Sync + 'static, B: Backend<Args = Args> + TaskSink<Args>,