Trait erdos::dataflow::operators::Concat

pub trait Concat<D> where
    D: Data + for<'a> Deserialize<'a>, {
    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>,