RxJS buffer

2020-10-14 09:48 更新

緩沖源的 Observable 值,直到 為止 closingNotifier發(fā)出 。

buffer<T>(closingNotifier: Observable<any>): OperatorFunction<T, T[]>

參量

關(guān)閉通知者 一個(gè)可觀察到的信號(hào) 要在輸出 Observable 上發(fā)出的緩沖區(qū)。

returns

OperatorFunction<T, T[]>:一個(gè)可觀察的緩沖區(qū),它是數(shù)組的 價(jià)值觀。

描述

收集過(guò)去的值作為數(shù)組,并發(fā)出 僅當(dāng)另一個(gè) Observable 發(fā)出時(shí),才返回該數(shù)組。

buffer marble diagram

緩沖傳入的 Observable 值,直到給定 closingNotifier Observable 發(fā)出一個(gè)值,此時(shí)它在輸出上發(fā)出緩沖區(qū) 可觀察并在內(nèi)部啟動(dòng)新緩沖區(qū),等待下一次 closingNotifier發(fā)出。

每次點(diǎn)擊時(shí),發(fā)出最近間隔事件的數(shù)組

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


const clicks = fromEvent(document, 'click');
const intervalEvents = interval(1000);
const buffered = intervalEvents.pipe(buffer(clicks));
buffered.subscribe(x => console.log(x));

也可以看看

以上內(nèi)容是否對(duì)您有幫助:
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號(hào)
微信公眾號(hào)

編程獅公眾號(hào)