How to force observables to execute in sequence?

by

If you want to be sure the order of emissions is the same as the order in which you specified the source Observables you can use concat or concatMap operators.

The concat* operators subscribe to an Observable only after the previous Observable completes (it works with Promises as well, see http://reactivex.io/rxjs/class/es6/MiscJSDoc.js~ObservableInputDoc.html).

In you case it’d look like the following:

import { concat } from 'rxjs'; // Note, concat from 'rxjs', is not the same as concat from 'rxjs/operators'

concat(printLog1, printLog23, printLog4);

… or with concatMap if the request for one Promise depends on the response from the previous Promise:

printLog1.pipe(
  concatMap(response => ...),
  concatMap(response => ...),
);

… or when the order doesn’t matter you can use merge that subscribes to all Observables/Promises immediately and reemits their results as they arrive:

merge(printLog1, printLog23, printLog4);

Jan 2019: Updated for RxJS 6

More Related Contents:

  1. When to use asObservable() in rxjs?
  2. Difference between .unsubscribe to .take(1)
  3. Rxjs: Observable.combineLatest vs Observable.forkJoin
  4. How to get an observable to return data immediately and every 5 seconds thereafter
  5. What is the correct way to share the result of an Angular Http network call in RxJs 5?
  6. Hot and Cold observables: are there ‘hot’ and ‘cold’ operators?
  7. How to return value from function which has Observable subscription inside?
  8. What are the semantics of different RxJS subjects?
  9. Chaining Observables in RxJS
  10. RxJS: takeUntil() Angular component’s ngOnDestroy()
  11. RxJS Observables nested subscriptions?
  12. ‘of’ vs ‘from’ operator
  13. Best way to “flatten” an array inside an RxJS Observable
  14. How to achieve a debounce service on input keyup event in angular2 with rxjs
  15. ngrx effects error handling
  16. Merge subarrays using Observables
  17. What is pipe for in RxJS?
  18. Observable Finally on Subscribe
  19. Is it necessary to unsubscribe from observables created by Http methods?
  20. Subscribe is deprecated: Use an observer instead of an error callback
  21. Promise.all behavior with RxJS Observables?
  22. Passing Data with Subjects and Proxies
  23. RxJS sequence equivalent to promise.then()?
  24. Rxjs One Observable Feeding into Another
  25. How to cancel/unsubscribe all pending HTTP requests in Angular 4+
  26. How to cancel a subscription in Angular2
  27. Behaviour subject initial value null?
  28. Observable.of is not a function
  29. How to correctly import operators from the `rxjs` package
  30. How to catch error and continue executing a sequence in RxJs?

Leave a Comment