RxJS - 轉換運算子 bufferWhen

此運算子將以陣列形式給出值，它接受一個引數作為函式，該函式將決定何時關閉、發出和重置緩衝區。

語法

bufferWhen(closing_func: Observable): Observable

引數

closing_func − 返回指示緩衝區關閉的可觀察物件的函式。

返回值

將返回一個可觀察物件，其中包含緩衝值的陣列。

示例

以下是 bufferWhen 的工作示例 −

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

let btn = document.getElementById("btnclick");
let btn_clicks = fromEvent(btn, 'click');
let buffered_array = btn_clicks.pipe(bufferWhen(() => interval(5000)));
buffered_array.subscribe(arr => console.log(arr));

對於 bufferWhen，我們給出了一個每隔 5 秒執行一次的函式。因此，每隔 5 秒，它將輸出記錄的所有點選，並重置並重新開始。

輸出