reduce

Накопление как Array.reduce, но эмитит только итог при complete.

Сигнатура

reduce(accumulator: (acc: R, value: T, index: number) => R, seed: R): OperatorFunction

Что делает

Хранит аккумулятор и обновляет его на каждом next. В отличие от scan, отдаёт только финальное значение после завершения источника.

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

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

См. также

scan, toArray, count