Categories: RxJS教程

RxJS：转换运算符bufferTime

这类似于bufferCount，因此在这里，它将从调用它的可观察对象中收集值，并发出bufferTimeSpan完成。它接受1个参数，即bufferTimeSpan。

语法

bufferTime(bufferTimeSpan: number): Observable

参量

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

返回值

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

例

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秒钟将显示一次点击，如下所示。