RxJS - Operador de transformación bufferTime

Esto es similar a bufferCount, por lo que aquí, recopilará los valores del observable en el que se llama y emitirá el bufferTimeSpan. Toma en 1 argumento, es decir,bufferTimeSpan.

Sintaxis

bufferTime(bufferTimeSpan: number): Observable

Parámetros

bufferTimeSpan - El tiempo para llenar la matriz de búfer.

Valor devuelto

Se devolverá un observable, que tendrá una matriz de valores almacenados en búfer.

Ejemplo

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));

En el ejemplo, el tiempo utilizado es de 4 segundos, por lo que el operador bufferTime () acumulará los clics y después de cada 4 segundos los mostrará como se muestra a continuación.

Salida