timely::dataflow::channels::pushers

Module buffer

Source
Expand description

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

Structsยง

  • A session which will flush itself when dropped.
  • Buffers data sent at the same time, for efficient communication.
  • An output session for sending records at a specified time.