RxJS - 转换操作符 bufferTime

这类似于 bufferCount，所以在这里，将收集要调用的可观察对象的值，然后在 bufferTimeSpan 完成时发出。它将获取 1 个参数，即 bufferTimeSpan。

语法

bufferTime(bufferTimeSpan: number): Observable

参数

bufferTimeSpan − 填充缓冲区数组的时间。

返回值

将返回一个可观察对象，其中包含一个已缓冲值的数组。

示例

import { fromEvent } from 'rxjs';
import { bufferTime } from 'rxjs/operators';

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

在该示例中，使用的时间为 4 秒，因此，bufferTime() 操作符将累积单击，并且每 4 秒后都会显示为如下所示。

输出