RXJS Wait for all observables in an array to complete (or error)

by

If you want to compose an observable that emits when all of the source observables complete, you can use forkJoin:

import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/forkJoin';
import 'rxjs/add/operator/first';

var tasks$ = [];
tasks$.push(Observable.timer(1000).first());
tasks$.push(Observable.timer(3000).first());
tasks$.push(Observable.timer(10000).first());
Observable.forkJoin(...tasks$).subscribe(results => { console.log(results); });

More Related Contents:

  1. Angular 7 go offline?
  2. Hot and Cold observables: are there ‘hot’ and ‘cold’ operators?
  3. How to get current value of RxJS Subject or Observable?
  4. BehaviorSubject vs Observable?
  5. Angular 4 Interceptor retry requests after token refresh
  6. Why do we need to use flatMap?
  7. How can I close a dropdown on click outside?
  8. What is “callback hell” and how and why does RX solve it?
  9. How can I `await` on an Rx Observable?
  10. What are the semantics of different RxJS subjects?
  11. Subject vs BehaviorSubject vs ReplaySubject in Angular
  12. Chaining Observables in RxJS
  13. Promise.all behavior with RxJS Observables?
  14. RxJS Promise Composition (passing data)
  15. RxJS sequence equivalent to promise.then()?
  16. Rxjs One Observable Feeding into Another
  17. Angular 2 – Chaining http requests
  18. Rxjs toPromise() deprecated
  19. How to make one Observable sequence wait for another to complete before emitting?
  20. How to achieve a debounce service on input keyup event in angular2 with rxjs
  21. How to cancel a subscription in Angular2
  22. Is it good to call subscribe inside subscribe?
  23. What is the difference between Observable and a Subject in rxjs?
  24. How to ‘wait’ for two observables in RxJS
  25. What is the difference between BehaviorSubject and Observable?
  26. Return an empty Observable
  27. Upgrading to Angular 10 – Fix CommonJS or AMD dependencies can cause optimization bailouts
  28. Property ‘catch’ does not exist on type ‘Observable’
  29. How to catch error and continue executing a sequence in RxJs?
  30. Observable Finally on Subscribe

Leave a Comment