使用關(guān)閉的工廠功能緩沖源 Observable 值 可以確定何時(shí)關(guān)閉，發(fā)出和重置緩沖區(qū)的可觀察對(duì)象。

bufferWhen<T>(closingSelector: () => Observable<any>): OperatorFunction<T, T[]>

參量

returns

OperatorFunction<T, T[]>：可觀察到的緩沖值數(shù)組。

描述

收集過(guò)去的值作為數(shù)組。 什么時(shí)候 開(kāi)始收集值，它調(diào)用一個(gè)函數(shù)，該函數(shù)返回一個(gè) Observable 告訴何時(shí)關(guān)閉緩沖區(qū)并重新開(kāi)始收集。

立即打開(kāi)緩沖區(qū)，然后在可觀察到的情況下關(guān)閉緩沖區(qū) 調(diào)用 返回 closingSelector函數(shù) 的值會(huì)發(fā)出一個(gè)值。 關(guān)門(mén)的時(shí)候 緩沖區(qū)，它將立即打開(kāi)一個(gè)新緩沖區(qū)并重復(fù)該過(guò)程。

例

每[1-5]秒隨機(jī)發(fā)出一次最終點(diǎn)擊的數(shù)組

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


const clicks = fromEvent(document, 'click');
const buffered = clicks.pipe(bufferWhen(() =>
  interval(1000 + Math.random() * 4000)
));
buffered.subscribe(x => console.log(x));

也可以看看

• buffer
• [bufferCount_blank]()_blank](http://www.15014759268.cn/rxjs/rxjs-usfc3chl.html)
• bufferTime
• bufferToggle
• windowWhen