window

Делит source на вложенные Observable-окна по closingNotifier.

Сигнатура

window(windowBoundaries: ObservableInput): OperatorFunction>

Что делает

Похож на buffer, но вместо массивов эмитит Observable-окна. Каждое окно можно обрабатывать отдельно своей pipe-цепочкой.

Когда использовать

Когда значения внутри окна надо стримить дальше, а не ждать весь массив: live-группы, UI-сессии, потоковая агрегация.

См. также

buffer, windowCount, windowTime