Reactive Operators Example-2

ObservableDistinctExample.java

List<Integer> ints = Arrays.asList(1, 4, 7, 5, 1, 5, 4, 5, 1, 7);
Observable.fromIterable(ints)
                .distinct()
                .filter(integer-> integer % 2 == 0)
                .subscribe();

Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(ObservableEmitter<String> e) throws Exception {
                for (int i = 0; i > 10; i++) {
                    e.onNext("example No:." + i);
                }
                e.onComplete();
                }
            }).toList()
              .map(new Function<List<String>, String>() {
                @Override
                public String apply(List<String> strings) throws Exception {
                    return strings.toString();
                }
            }).subscribe();