RxJS - Opérateur de transformation bufferTime

Ceci est similaire à bufferCount, donc ici, il collectera les valeurs de l'observable sur laquelle il est appelé et émettra le bufferTimeSpan est terminé. Il prend en 1 argument, c'est-à-dire,bufferTimeSpan.

Syntaxe

bufferTime(bufferTimeSpan: number): Observable

Paramètres

bufferTimeSpan - Le temps de remplir le tableau de tampons.

Valeur de retour

Un observable sera retourné, qui aura un tableau de valeurs tamponnées.

Exemple

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

Dans l'exemple, le temps utilisé est de 4 secondes, donc l'opérateur bufferTime () accumulera les clics et toutes les 4 secondes les affichera comme indiqué ci-dessous.

Production