Struct Pipe 

pub struct Pipe<I, O> { /* private fields */ }

A Pipe represents a rs2_stream transformation from one type to another. It’s a function from Stream[I] to Stream[O].

Implementations

impl<I, O> Pipe<I, O>

pub fn new<F>(f: F) -> Self

where F: Fn(RS2Stream<I>) -> RS2Stream<O> + Send + Sync + 'static,

Create a new pipe from a function

pub fn apply(&self, input: RS2Stream<I>) -> RS2Stream<O>

Apply this pipe to a rs2_stream

Trait Implementations

impl<I, O> Clone for Pipe<I, O>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<I, O> PipeExt<I, O> for Pipe<I, O>

where I: Send + 'static, O: Send + 'static,

fn compose<P>(self, other: Pipe<O, P>) -> Pipe<I, P>

where P: Send + 'static,

Compose this pipe with another pipe