Module timely::dataflow::channels::pushers[][src]

A collection of types that may be pushed at.

Re-exports

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

Modules

buffer

Buffering and session mechanisms to provide the appearance of record-at-a-time sending, with the performance of batched sends.

counter

A wrapper which counts the number of records pushed past and updates a shared count map.

exchange

The exchange pattern distributes pushed data between many target pushees.

tee

A Push implementor with a list of Box<Push> to forward pushes to.