Module timely::dataflow::channels::pushers

source ·
Expand description

A collection of types that may be pushed at.



  • Buffering and session mechanisms to provide the appearance of record-at-a-time sending, with the performance of batched sends.
  • A wrapper which counts the number of records pushed past and updates a shared count map.
  • The exchange pattern distributes pushed data between many target pushees.
  • A Push implementor with a list of Box<Push> to forward pushes to.