Module enterleave

Extension traits to move a Stream between an outer Scope and inner Scope.

Each Stream indicates its containing Scope as part of its type signature. To create a new stream with the same contents in another scope, one must explicit use the methods enter and leave, to clearly indicate the transition to the timely dataflow progress tracking logic.

Examples

use timely::dataflow::scopes::Scope;
use timely::dataflow::operators::{Enter, Leave, ToStream, Inspect};

timely::example(|outer| {
    let stream = (0..9).to_stream(outer);
    let output = outer.region(|inner| {
        stream.enter(inner)
              .inspect(|x| println!("in nested scope: {:?}", x))
              .leave()
    });
});

Traits

Enter

Extension trait to move a Stream into a child of its current Scope.

Leave

Extension trait to move a Stream to the parent of its current Scope.