Transforming Operator Buffer RxJava

RxTransformingOperatorBuffer.java

public class RxTransformingOperatorBuffer {
    public static void main(String[] args) throws InterruptedException {
        String[] names = new String[]{"Yudi Setiawan", "Rosalia", "Harli Lopies", "Fitriani"};
        Observable.fromArray(names)
                .buffer(3)
                .subscribe(System.out::println);
    }
}