window

Splits source into nested Observable windows by a closingNotifier.

Signature

window(windowBoundaries: ObservableInput): OperatorFunction>

What it does

Like buffer, but emits Observable windows instead of arrays. Each window can be processed separately with its own pipe chain.

When to use

When the values inside a window should be streamed on rather than waiting for the whole array: live groups, UI sessions, streaming aggregation.

See also

buffer, windowCount, windowTime