Crate stream_window

source ·
Expand description

Stream windows build on top of async streams. Implementations offered:

  • tumbling window, waits till window of specified size is filled, emits, and starts a new window
  • sliding window, waits till window of specified size is filled, emits, and slides down by one element
  • periodic window, waits till window of specified size is filled, emits, and starts a new window on a clock tick

Traits

  • WindowExt
    Wrappers for actual window implementations, as an extension trait.

Functions

  • to_periodic_window
    Periodic window, waits till window of specified size is filled, emits, and starts a new window on a clock tick.
  • to_sliding_window
    Sliding window, waits till window of specified size is filled, emits, and slides down by one element.
  • to_tumbling_window
    Tumbling window, waits till window of specified size is filled, emits, and starts a new window.