RxJS count

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

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

參量

returns

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

描述

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

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

例子

計(jì)算第一次點(diǎn)擊之前經(jīng)過(guò)了多少秒

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));

計(jì)算1到7之間有多少個(gè)奇數(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