Trait Concat

pub trait Concat<D>
where
    D: Data + for<'a> Deserialize<'a>,
{
    // Required method
    fn concat(&self, other: &dyn Stream<D>) -> OperatorStream<D>;
}

Extension trait for merging the contents of two streams.

Names the ConcatOperator using the names of the two merged streams.

Example

let merged_stream = left_stream.concat(&right_stream);

Required Methods

fn concat(&self, other: &dyn Stream<D>) -> OperatorStream<D>

Implementors

impl<S, D> Concat<D> for S

where S: Stream<D>, D: Data + for<'a> Deserialize<'a>,