Trait timely::dataflow::operators::enterleave::Enter
[−]
[src]
pub trait Enter<G: Scope, T: Timestamp, D: Data> { fn enter(&self, &Child<G, T>) -> Stream<Child<G, T>, D>; }
Extension trait to move a Stream
into a child of its current Scope
.
Required Methods
fn enter(&self, &Child<G, T>) -> Stream<Child<G, T>, D>
Moves the Stream
argument into a child 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() }); });