RxJS bufferToggle

緩沖源可觀察值，從 openings并在 輸出時(shí)結(jié)束 closingSelector發(fā)出 。

                  bufferToggle<T, O>(openings: SubscribableOrPromise<O>, closingSelector: (value: O) => SubscribableOrPromise<any>): OperatorFunction<T, T[]>    

參量

returns

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

描述

收集過去的值作為數(shù)組。 開始 僅在 時(shí)收集 opening發(fā)射 ，并調(diào)用 closingSelector 函數(shù)獲得一個(gè) Observable，該變量指示何時(shí)關(guān)閉緩沖區(qū)。

通過來自的信號(hào)打開緩沖區(qū)來緩沖來自源的值 提供給的 Observable openings，并在以下情況關(guān)閉并發(fā)送緩沖區(qū) 該 返回的 Subscribable 或 Promise closingSelector函數(shù) 發(fā)出。

例

每隔一秒鐘，從接下來的 500ms 發(fā)出點(diǎn)擊事件

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


const clicks = fromEvent(document, 'click');
const openings = interval(1000);
const buffered = clicks.pipe(bufferToggle(openings, i =>
  i % 2 ? interval(500) : EMPTY
));
buffered.subscribe(x => console.log(x));

也可以看看

• buffer
• bufferCount
• bufferTime
• bufferWhen
• windowToggle