Transforming Operator groupBy

RxTransformingOperatorGroupBy.java

public class RxTransformingOperatorGroupBy {
    public static void main(String[] args) {
        Observable.range(1, 9)
                .groupBy(item -> item % 2 == 0 ? "Genap" : "Ganji")
                .subscribe(groupObservable -> {
                    if (groupObservable.getKey().equalsIgnoreCase("Genap")) {
                        System.out.println("Emit bilangan genap");
                        System.out.println("List bilangan genap adalah sebagai berikut.");
                        groupObservable.subscribe(System.out::println);
                    } else {
                        System.out.println("Emit bilangan ganjil");
                    }
                });
    }
}