RxJava Kesişim Kümesi Bulmak
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)
rxjava
RxJava 1’den 100’e kadar çift sayıların toplamı
Observable.range(0, 100).filter(x->x%2 == 0) .reduce((x,y)->x+y).subscribe(System.out::println);
RxJava 1’den 100’e kadar asal sayıları bulmak
Observable.range(2, 100).filter(x -> Observable.range(2, x).filter(y -> x % y == 0).blockingFirst() == x)