Making sure observables in for loop are all finished before executing other code

by

You should make use of RxJS’s forkJoin to wait for the for..of loop to be completed before returning all the observables.

Here are the changes you should make to your code:

getPersons().subscribe(
  persons => {
    const observablesList = [];
    for (const person of persons) {
      const getAddressObservable = getAddress(person.id);
      observablesList.push(getAddressObservable)
    }
    forkJoin(observablesList).subscribe(response => {
      // console.log(response) to check that there is a list of returned observables
      const result = persons.map((person, index) => {
        person['address'] = response[index]['address'];
        return person;
      })
      doSomethingWithAddresses();
    })
  }
);

Alternatively, you may try this to prevent the chaining of subscribe()

getPersons().pipe(
  mergeMap(persons => {
    const observablesList = [];
    for (const person of persons) {
      const getAddressObservable = getAddress(person.id);
      observablesList.push(getAddressObservable)
    }
    return observablesList;
  })
).subscribe(response => {
  // console.log(response) to check that there is a list of returned observables
  const result = persons.map((person, index) => {
    person['address'] = response[index]['address'];
    return person;
  })
  doSomethingWithAddresses();
})

More Related Contents:

  1. What is the difference between Promises and Observables?
  2. What is the difference between Subject and BehaviorSubject?
  3. Angular HTTP GET with TypeScript error http.get(…).map is not a function in [null]
  4. Avoiding nesting subscriptions in Angular 2+?
  5. Convert Promise to Observable
  6. Observable type error: cannot read property of undefined
  7. RxJS: takeUntil() Angular component’s ngOnDestroy()
  8. Angular Subscribe within Subscribe
  9. How to create an RXjs RetryWhen with delay and limit on tries
  10. Handling refresh tokens using rxjs
  11. Best way to “flatten” an array inside an RxJS Observable
  12. How to make an http call every 2 minutes with RXJS?
  13. Angular 7 – nesting Observables
  14. Angular subscribe elegant
  15. Best way to import Observable from rxjs
  16. TypeError: You provided an invalid object where a stream was expected. You can provide an Observable, Promise, Array, or Iterable
  17. rxjs/Subject.d.ts error : Class ‘Subject’ incorrectly extends base class ‘Observable’
  18. Rxjs Retry with Delay function
  19. How to make nested Observable calls in Angular2
  20. tap() isn’t triggered in RXJS Pipe
  21. What is pipe for in RxJS?
  22. How to throw error from RxJS map operator (angular)
  23. How to return observable from subscribe
  24. Property ‘toPromise’ does not exist on type ‘Observable’
  25. How to receive blob responses using Angular’s 2+ @angular/http module?
  26. Angular 5 to 6 Upgrade: Property ‘map’ does not exist on type Observable
  27. Angular2 watch for 302 redirect when fetching resource
  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