Trait timely::dataflow::operators::enterleave::Leave

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

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

Required Methods

fn leave(&self) -> Stream<G, D>

Moves a Stream to the parent of its current Scope.

Examples

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

timely::example(|outer| {
    let stream = (0..9).to_stream(outer);
    let output = outer.scoped::<u32,_,_>(|inner| {
        stream.enter(inner).leave()
    });
});

Implementors

• impl<'a, G: Scope, D: Data, T: Timestamp> Leave<G, D> for Stream<Child<'a, G, T>, D>