RxJS buffer

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

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

參量

returns

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

描述

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

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

例

每次點擊時，發(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));

也可以看看

• bufferCount
• bufferTime
• bufferToggle
• bufferWhen
• window