RxJS reduce

在源 Observable 上應用累加器函數，并在給定可選種子值的情況下在源完成時返回累加結果。

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

參量

returns

OperatorFunction<T, T | R>：一個 Observable 發(fā)出一個值，該值是對源 Observable 發(fā)出的值進行累加的結果。

描述

使用累加器函數將源上發(fā)出的所有值合并在一起，該函數知道如何將新的源值結合到過去的累加中。

像 Array.prototype.reduce（）一樣 ， 對累積和源 Observable 的每個值（過去）reduce應用一個accumulator函數，以將其減少為單個值，并在輸出 Observable 上發(fā)出該值。請注意reduce，僅當源 Observable 完成時才會發(fā)出一個值。等效于應用運算符，scan然后是 operator last。

返回一個 Observable，它將一個指定的accumulator函數應用于源 Observable 發(fā)出的每個項目。如果 seed 指定了一個值，則該值將用作累加器的初始值。如果未指定種子值，則將源的第一項用作seed。

例

計算 5 秒鐘內發(fā)生的點擊事件數

import { fromEvent, interval } from 'rxjs';
import { reduce, takeUntil, mapTo } from 'rxjs/operators';


const clicksInFiveSeconds = fromEvent(document, 'click').pipe(
  takeUntil(interval(5000)),
);
const ones = clicksInFiveSeconds.pipe(mapTo(1));
const seed = 0;
const count = ones.pipe(reduce((acc, one) => acc + one, seed));
count.subscribe(x => console.log(x));

超載

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

returnsOperatorFunction<T, R>
reduce(accumulator: (acc: T, value: T, index: number) => T, seed?: T): MonoTypeOperatorFunction<T>

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

returnsOperatorFunction<T, R>

也可以看看

• count
• expand
• [mergeScan_blank]()_blank](http://www.o2fo.com/rxjs/rxjs-4rka3ciu.html)
• scan