pub trait ConnectLoop<G: Scope, D: Container> {
// Required method
fn connect_loop(&self, _: HandleCore<G, D>);
}Expand description
Connect a Stream to the input of a loop variable.
Required Methods§
sourcefn connect_loop(&self, _: HandleCore<G, D>)
fn connect_loop(&self, _: HandleCore<G, D>)
Connect a Stream to be the input of a loop variable.
§Examples
use timely::dataflow::Scope;
use timely::dataflow::operators::{Feedback, ConnectLoop, ToStream, Concat, Inspect, BranchWhen};
timely::example(|scope| {
// circulate 0..10 for 100 iterations.
let (handle, cycle) = scope.feedback(1);
(0..10).to_stream(scope)
.concat(&cycle)
.inspect(|x| println!("seen: {:?}", x))
.branch_when(|t| t < &100).1
.connect_loop(handle);
});