timely/dataflow/channels/pushers/mod.rs
1pub use self::tee::{Tee, TeeHelper};
2pub use self::exchange::Exchange;
3pub use self::counter::Counter;
4
5pub mod tee;
6pub mod exchange;
7pub mod counter;
8pub mod progress;
9
10/// An output pusher which validates capabilities, records progress, and tees output.
11pub type Output<T, C> = progress::Progress<T, counter::Counter<T, tee::Tee<T, C>>>;
12/// An output session that will flush the output when dropped.
13pub type OutputSession<'a, T, C> = progress::ProgressSession<'a, T, C, counter::Counter<T, tee::Tee<T, C>>>;