Trait timely::dataflow::operators::concat::Concatenate

pub trait Concatenate<G: Scope, D: Data> {
    fn concatenate(&self, _: Vec<Stream<G, D>>) -> Stream<G, D>;
}

Merge the contents of multiple streams.

Required Methods

fn concatenate(&self, _: Vec<Stream<G, D>>) -> Stream<G, D>

Merge the contents of multiple streams.

Examples

use timely::dataflow::operators::{ToStream, Concatenate, Inspect};

timely::example(|scope| {

    let streams = vec![(0..10).to_stream(scope),
                       (0..10).to_stream(scope),
                       (0..10).to_stream(scope)];

    scope.concatenate(streams)
         .inspect(|x| println!("seen: {:?}", x));
});

Implementors

• impl<G: Scope, D: Data> Concatenate<G, D> for G