Expand description
Abstractions for timely dataflow programming.
Timely dataflow programs are constructed by manipulating Stream objects,
most often using pre-defined operators that implement known patterns.
§Examples
use timely::dataflow::operators::{ToStream, Inspect};
timely::example(|scope| {
(0..10).to_stream(scope)
.inspect(|x| println!("seen: {:?}", x));
});Re-exports§
pub use self::stream::StreamCore;pub use self::stream::Stream;pub use self::scopes::Scope;pub use self::scopes::ScopeParent;pub use self::operators::core::input::Handle as InputHandleCore;pub use self::operators::input::Handle as InputHandle;pub use self::operators::probe::Handle as ProbeHandle;