Combine a list of Observables and wait until all completed

by

You can use flatMap in case you have dynamic tasks composition. Something like this:

public Observable<Boolean> whenAll(List<Observable<Boolean>> tasks) {
    return Observable.from(tasks)
            //execute in parallel
            .flatMap(task -> task.observeOn(Schedulers.computation()))
            //wait, until all task are executed
            //be aware, all your observable should emit onComplete event
            //otherwise you will wait forever
            .toList()
            //could implement more intelligent logic. eg. check that everything is successful
            .map(results -> true);
}

Another good example of parallel execution

Note: I do not really know your requirements for error handling. For example, what to do if only one task fails. I think you should verify this scenario.

More Related Contents:

  1. Use cases for RxJava schedulers
  2. Paginate Observable results without recursion – RxJava
  3. RxJava Fetching Observables In Parallel
  4. When do you use map vs flatMap in RxJava?
  5. Rxjava Android how to use the Zip operator
  6. Correct way of throwing exceptions with Reactor
  7. What’s the point of .switchIfEmpty() getting evaluated eagerly?
  8. rxjava: Can I use retry() but with delay?
  9. RxJava instead of AsyncTask?
  10. RxJava delay for each item of list emitted
  11. How to get String from Mono in reactive java
  12. block()/blockFirst()/blockLast() are blocking error when calling bodyToMono AFTER exchange()
  13. Retrofit and RxJava: How to combine two requests and get access to both results?
  14. What is the difference between concatMap and flatMap in RxJava
  15. How to customize SpringWebFlux WebClient JSON deserialization?
  16. Can I use SpringMvc and webflux together?
  17. RxJava and parallel execution of observer code
  18. Mono switchIfEmpty() is always called
  19. Super class constructor called last in Swift, but called first in Java? [closed]
  20. Download a file with Android, and showing the progress in a ProgressDialog
  21. How can I pad a String in Java?
  22. Calling Non-Static Method In Static Method In Java [duplicate]
  23. Should I actually remove the ValueEventListener?
  24. Comparing strings with == which are declared final in Java
  25. How does java do modulus calculations with negative numbers?
  26. Stretch a JLabel text
  27. How to implement in Java ( JTextField class ) to allow entering only digits?
  28. Double cannot be dereferenced?
  29. What is the equivalent of Regex-replace-with-function-evaluation in Java 7?
  30. Create session factory in Hibernate 4

Leave a Comment