Crate stream_window

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.