Buffers the source Observable values until the size hits the maximum bufferSize given
소스 스트림의 방출값을 주어진 버퍼사이즈만큼 버퍼에 채운후 방출한다.
let stream$ = of(1,2,3,4,5,6,7);
stream$.pipe(
bufferCount(3)
).subscribe(console.log)
1,2,3 / 4,5,6 / 7
let stream$ = of(1,2,3,4,5,6,7);
stream$.pipe(
bufferCount(3,2)
).subscribe(console.log)
1,2,3 / 3,4,5 / 5,6,7
let stream$ = interval(1000);
stream$.pipe(
bufferCount(3,2)
).subscribe(console.log)
1,2,3 / 3,4,5 / 5,6,7 .....
버퍼가 채워지면 자동으로 방출된다.