RxJS scan

在源 Observable 上應(yīng)用累加器函數(shù)，并返回每個(gè)中間結(jié)果以及可選的seed值。

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

參量

returns

OperatorFunction<T, R>：可觀察到的累積值。

描述

就像reduce，但是只要源發(fā)出一個(gè)值，就發(fā)出電流累積。

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

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

例

計(jì)算點(diǎn)擊事件的數(shù)量

import { fromEvent } from 'rxjs';
import { scan, mapTo } from 'rxjs/operators';


const clicks = fromEvent(document, 'click');
const ones = clicks.pipe(mapTo(1));
const seed = 0;
const count = ones.pipe(scan((acc, one) => acc + one, seed));
count.subscribe(x => console.log(x));

超載

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

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

returnsMonoTypeOperatorFunction<T>

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

returnsOperatorFunction<T, R>

也可以看看

• expand
• mergeScan
• reduce