How to make nested Observable calls in Angular2

by

You should read up on rxjs’s operators a little. Your examples are very verbose and use flatMap and map in a way they’re not supposed to be used. Also your first example can’t work, because you’re not subscribing to the Observable.

This will do what you need:

ngOnInit() {
    this.userService.getUser().pipe(
        tap(u => this.user = u),
        flatMap(u => this.userService.getPreferences(u.username))
      ).subscribe(p => this.preferences = p);
}

legacy:

Before version 5.5 rxjs exclusively used prototype-based operators.
This code is functionally equivalent to the above:

ngOnInit() {
    this.userService.getUser()
        .do(u => this.user = u) //.do just invokes the function. does not manipulate the stream, return value is ignored.
        .flatMap(u => this.userService.getPreferences(u.username))
        .subscribe(p => this.preferences = p);
}

More Related Contents:

  1. take(1) vs first()
  2. Best way to import Observable from rxjs
  3. Angular/RxJS When should I unsubscribe from `Subscription`
  4. What is the correct way to share the result of an Angular Http network call in RxJs 5?
  5. Is it necessary to unsubscribe from observables created by Http methods?
  6. Angular HTTP GET with TypeScript error http.get(…).map is not a function in [null]
  7. Avoiding nesting subscriptions in Angular 2+?
  8. Subject vs BehaviorSubject vs ReplaySubject in Angular
  9. RxJS: takeUntil() Angular component’s ngOnDestroy()
  10. Angular Subscribe within Subscribe
  11. Passing Data with Subjects and Proxies
  12. How to cancel/unsubscribe all pending HTTP requests in Angular 4+
  13. Testing error case with observables in services
  14. How to make a sequence of http requests in Angular 6 using RxJS
  15. Angular subscribe elegant
  16. TypeError: You provided an invalid object where a stream was expected. You can provide an Observable, Promise, Array, or Iterable
  17. Behaviour subject initial value null?
  18. Observable.of is not a function
  19. fromPromise does not exist on type Observable
  20. Rxjs Retry with Delay function
  21. tap() isn’t triggered in RXJS Pipe
  22. How to correctly import operators from the `rxjs` package
  23. Subscribing to a nested Observable
  24. How to return observable from subscribe
  25. Property ‘toPromise’ does not exist on type ‘Observable’
  26. How to return value inside subscribe Angular 4
  27. How to receive blob responses using Angular’s 2+ @angular/http module?
  28. FormControl.detectchanges – why use distinctUntilChanged?
  29. How to pass results between chained observables
  30. Do we need to unsubscribe from observable that completes/errors-out?

Leave a Comment