bufferCount

Накапливает значения в массив фиксированной длины и эмитит его.

Сигнатура

bufferCount(bufferSize: number, startBufferEvery?: number): OperatorFunction

Маркеры

in:           --1-2-3-4-5--|
bufferCount(2): ----[1,2]-[3,4]-[5]-|

Что делает

Собирает next в массив длиной bufferSize и эмитит готовый буфер. При завершении потока эмитит остаток (даже если он меньше bufferSize). Параметр startBufferEvery контролирует скользящие окна.

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

Батчинг событий перед отправкой (логи, аналитика), группировка сообщений WebSocket, чанковая загрузка.

См. также

bufferTime, window, pairwise