Reference · 68

groupBy

Разбивает поток на группы по ключу.

groupBy(keySelector: (value: T) => K): OperatorFunction>

Эмитит GroupedObservable для каждого нового ключа. Каждый grouped$ содержит только значения своего ключа и имеет свойство key.

Группировка событий по userId/type/status, раздельная обработка каналов внутри одного общего потока.

Подводный камень

Каждая группа живёт до завершения источника или duration. На бесконечных потоках без duration можно получить рост числа групп.

mergeMap, toArray

script.ts // TypeScript

CONSOLE · Console Output

Нажмите на запуск, чтобы увидеть результат...