Trait Concat 

pub trait Concat<G: Scope, C> {
    // Required method
    fn concat(self, other: Stream<G, C>) -> Stream<G, C>;
}

Merge the contents of two streams.

Required Methods

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

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.clone()
          .concat(stream)
          .container::<Vec<_>>()
          .inspect(|x| println!("seen: {:?}", x));
});

Implementors

impl<G: Scope, C: Container> Concat<G, C> for Stream<G, C>