RxJS count

計算源的發(fā)射數(shù)量，當(dāng)源完成。

count<T>(predicate?: (value: T, index: number, source: Observable<T>) => boolean): OperatorFunction<T, number>

參量

returns

OperatorFunction<T, number>：一個數(shù)字的 Observable，代表計數(shù)為 如上所述。

描述

告訴您在什么時候發(fā)出了多少個值 完成。

count將發(fā)出值的 Observable 轉(zhuǎn)換為 發(fā)出一個值，該值代表 來源可觀察。 如果源 Observable 因錯誤而終止， count 將傳遞此錯誤通知，而無需先發(fā)出值。 如果 源 Observable 根本不會終止， count也不會發(fā)出 一個值也不終止。 該運算符具有可選 predicate功能 作為參數(shù)，在這種情況下，輸出排放將代表 源值匹配 true與 predicate。

例子

計算第一次點擊之前經(jīng)過了多少秒

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


const seconds = interval(1000);
const clicks = fromEvent(document, 'click');
const secondsBeforeClick = seconds.pipe(takeUntil(clicks));
const result = secondsBeforeClick.pipe(count());
result.subscribe(x => console.log(x));

計算1到7之間有多少個奇數(shù)

import { range } from 'rxjs';
import { count } from 'rxjs/operators';


const numbers = range(1, 7);
const result = numbers.pipe(count(i => i % 2 === 1));
result.subscribe(x => console.log(x));
// Results in:
// 4

也可以看看

• max
• min
• reduce