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//!            .inspect(|x| println!("seen: {:?}", x));
13//! });
14//! ```
15
16pub use self::stream::{StreamCore, Stream};
17pub use self::scopes::{Scope, ScopeParent};
18
19pub use self::operators::core::input::Handle as InputHandleCore;
20pub use self::operators::input::Handle as InputHandle;
21pub use self::operators::probe::Handle as ProbeHandle;
22
23pub mod operators;
24pub mod channels;
25pub mod scopes;
26pub mod stream;