Trait timely::dataflow::operators::concat::Concat

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

Merge the contents of two streams.

Required methods

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

Merge the contents of two streams.

Examples

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

timely::example(|scope| {

    let stream = (0..10).to_stream(scope);
    stream.concat(&stream)
          .inspect(|x| println!("seen: {:?}", x));
});

Loading content...

Implementors

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

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

Loading content...