RxJS：转换运算符bufferWhen

该运算符将以数组形式给出值，它将一个参数作为函数来决定何时关闭，发出和重置buffer。

语法

bufferWhen(closing_func: Observable): Observable

参量

closing_func – 一个返回Observable指示缓冲区关闭的函数。

返回值

将返回一个observable，它将具有一个缓冲值数组。

例

这是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秒，它将输出记录的所有点击次数，并将重置并重新开始。