timely/dataflow/mod.rs
1//! Abstractions for timely dataflow programming.
2//!
3//! Timely dataflow programs are constructed by manipulating [`Stream`](stream) objects,
4//! most often using pre-defined [operators] that implement known patterns.
5//!
6//! # Examples
7//! ```
8//! use timely::dataflow::operators::{ToStream, Inspect};
9//!
10//! timely::example(|scope| {
11//! (0..10).to_stream(scope)
12//! .container::<Vec<_>>()
13//! .inspect(|x| println!("seen: {:?}", x));
14//! });
15//! ```
16
17pub use self::stream::{Stream, StreamVec};
18pub use self::scopes::{Scope, ScopeParent};
19
20pub use self::operators::core::input::Handle as InputHandle;
21pub use self::operators::vec::input::Handle as InputHandleVec;
22pub use self::operators::probe::Handle as ProbeHandle;
23
24pub mod operators;
25pub mod channels;
26pub mod scopes;
27pub mod stream;