[RxJava] buffer

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);
    }
}