📌 Buffer 연산자란?

Observable로부터 정기적으로 항목들을 수집하고 묶음으로 만든 후에 묶음 안에 있는 항목들을 한번에 하나씩 배출하지 않고 수집된 묶음 단위로 배출한다. 이를 통해 데이터를 일정한 크기의 그룹으로 나누거나, 일정 시간 간격으로 데이터를 모아서 처리할 수 있다.

📌 Buffer 사용법

buffer 연산자 파라미터에 몇 개를 묶을 것인지를 넣어주면 됩니다. 그리고 buffer는 여러가지 overloading이 존재합니다.

1. 기본 buffer

buffer(int count) // 3를 넣으면 3개씩 묶어서 발행

2. count 갯수를 모을때마다 다음 skip 갯수는 건너뛴다.

buffer(int count, int skip) // 3,1를 넣으면 3개를 묶어서 발행 후 다음 1개는 건너뛴다.

3. 지정된 시간 만큼 데이터를 모으고 발행간다.

buffer(long timespan, TimeUnit unit)//지정된 시간 간격에 따라 데이터를 모아서 리스트로 발행한다.