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

pub trait Concatenate<G: Scope, D: Data> {
    fn concatenate<I>(&self, sources: I) -> Stream<G, D>
    where
        I: IntoIterator<Item = Stream<G, D>>;
}

Merge the contents of multiple streams.

Required methods

fn concatenate<I>(&self, sources: I) -> Stream<G, D> where
    I: IntoIterator<Item = 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));
});

Loading content...

Implementors

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

fn concatenate<I>(&self, sources: I) -> Stream<G, D> where
    I: IntoIterator<Item = Stream<G, D>>, 

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

fn concatenate<I>(&self, sources: I) -> Stream<G, D> where
    I: IntoIterator<Item = Stream<G, D>>, 

Loading content...