RxJava Kesişim Kümesi Bulmak

Posted by dogukanhan on October 06, 2018 · 1 min read
Observable<Integer> two = Observable.range(0, 100).filter(x->x%2==0);
Observable<Integer> three= Observable.range(0, 100).filter(x->x%3==0);
three.filter(y->two.contains(y).blockingGet()).subscribe(System.out::println)