buffer buffer는 말 그대로 버퍼에 담아서 통지를 하는 것. import io.reactivex.Flowable; import java.util.concurrent.TimeUnit; public class Buffer { public static void main(String[] args) throws Exception { Flowable.interval(100L, TimeUnit.MILLISECONDS) .take(12) //12건통지 .buffer(3) //3개씩 모아서 통지 .subscribe(data -> System.out.println(data)); Thread.sleep(4000L); } }