RxJS - Operatore di trasformazione bufferTime

Questo è simile a bufferCount, quindi qui raccoglierà i valori dall'osservabile su cui è chiamato ed emetterà il bufferTimeSpan. Richiede 1 argomento, ovverobufferTimeSpan.

Sintassi

bufferTime(bufferTimeSpan: number): Observable

Parametri

bufferTimeSpan - Il tempo necessario per riempire l'array di buffer.

Valore di ritorno

Verrà restituito un osservabile, che avrà un array di valori bufferizzati.

Esempio

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

Nell'esempio il tempo utilizzato è di 4 secondi, quindi l'operatore bufferTime () accumulerà i clic e dopo ogni 4 secondi li visualizzerà come mostrato di seguito.

Produzione