How to combine multiple async RxJava Observables?

Question

What's the best way to subscribe to two different Observables and then block until both are complete?

    Observable<Integer> o1 = getSomeInts();
    Observable<Long> o2 = getSomeOtherLongs();

    o1.forEach(it -> sendSomeEvent(it)); // doesn't have to be forEach
    o2.forEach(it -> sendSomeOtherEvent(it));

    // block until o1 and o2 are complete

Dave Moten · Accepted Answer · 2015-08-11 23:14:00Z

3

This would do it:

Observable.merge(
        o1.doOnNext(it -> sendSomeEvent(it)).ignoreElements(),
        o2.doOnNext(it -> sendSomeOtherEvent(it)).ignoreElements())
    .count().toBlocking().single();

answered Aug 11, 2015 at 23:14

Dave Moten

12.1k2 gold badges45 silver badges48 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

Dave Moten Over a year ago

oops had used forEach instead of doOnNext, fixed

Collectives™ on Stack Overflow

How to combine multiple async RxJava Observables?

1 Answer 1

1 Comment

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Your Answer

Sign up or log in

Post as a guest

Related