Demo:  bufferTime

bufferTime operator keeps collecting the incoming data into a new array and emits every interval specified in miliseconds.

bufferTime(intervalInMiliseconds)

let input = timer(0,1500).pipe(take(7));

//buffers and emits every 2 sec
let process = bufferTime(2000);

let output=input.pipe(process).subscribe(v=>console.log(v))