RxJS reduce

在源 Observable 上應(yīng)用累加器函數(shù)，并在給定可選種子值的情況下在源完成時返回累加結(jié)果。

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ā)出的值進(jìn)行累加的結(jié)果。

描述

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

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

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

例

計(jì)算 5 秒鐘內(nèi)發(fā)生的點(diǎn)擊事件數(shù)

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://o2fo.com/rxjs/rxjs-4rka3ciu.html)
• scan