bufferCount

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 .....

버퍼가 채워지면 자동으로 방출된다.