Rxjs One Observable Feeding into Another

by

For transforming items emitted by an Observable into another Observable, you probably want to use the flatMap operator. It creates an inner Observable and flats its result to the outer stream.

const source = this.myService
    .getFoo()
    .pipe(
        flatMap(result => this.myService.getMoo(result))
     )
    .subscribe(result2 => {
        // do some stuff
    });

Here are some flat operators you can use that behave differently:

  • flatMap/mergeMap – creates an Observable immediately for any source item, all previous Observables are kept alive
  • concatMap – waits for the previous Observable to complete before creating the next one
  • switchMap – for any source item, completes the previous Observable and immediately creates the next one
  • exhaustMap – map to inner observable, ignore other values until that observable completes

More Related Contents:

  1. Promise.all behavior with RxJS Observables?
  2. What are use cases for mergeMap operator?
  3. How to make one Observable sequence wait for another to complete before emitting?
  4. Is it good to call subscribe inside subscribe?
  5. Return an empty Observable
  6. Angular 7 go offline?
  7. How do I return the response from an Observable/http/async call in angular?
  8. Hot and Cold observables: are there ‘hot’ and ‘cold’ operators?
  9. Angular 4 Interceptor retry requests after token refresh
  10. Why do we need to use flatMap?
  11. How can I close a dropdown on click outside?
  12. What is “callback hell” and how and why does RX solve it?
  13. How can I `await` on an Rx Observable?
  14. What are the semantics of different RxJS subjects?
  15. Subject vs BehaviorSubject vs ReplaySubject in Angular
  16. Chaining Observables in RxJS
  17. How to do the chain sequence in rxjs
  18. RxJS Promise Composition (passing data)
  19. Is it a good practice using Observable with async/await?
  20. RxJS sequence equivalent to promise.then()?
  21. RXJS Wait for all observables in an array to complete (or error)
  22. Angular 2 – Chaining http requests
  23. Rxjs toPromise() deprecated
  24. How to cancel a subscription in Angular2
  25. What is the difference between Observable and a Subject in rxjs?
  26. How to ‘wait’ for two observables in RxJS
  27. Property ‘catch’ does not exist on type ‘Observable’
  28. How to catch error and continue executing a sequence in RxJs?
  29. How to implement a global loader in Angular
  30. Observable.forkJoin with a for loop

Leave a Comment