Trait timely::dataflow::operators::enterleave::Leave
[−]
[src]
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() }); });