timely 0.29.0

A low-latency data-parallel dataflow system in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

pub use self::tee::{Tee, TeeHelper};
pub use self::exchange::Exchange;
pub use self::counter::Counter;

pub mod tee;
pub mod exchange;
pub mod counter;
pub mod progress;

/// An output pusher which validates capabilities, records progress, and tees output.
pub type Output<T, C> = progress::Progress<T, counter::Counter<T, tee::Tee<T, C>>>;
/// An output session that will flush the output when dropped.
pub type OutputSession<'a, T, C> = progress::ProgressSession<'a, T, C, counter::Counter<T, tee::Tee<T, C>>>;