Observable - Faire la queue des demandes dynamiques (angulaire 4)

Question

J'ai une question à propos de observable. Par exemple, nous avons api, et envoyer un reguest là:

this.http.get('https://swapi.co/api/people/').subscribe(peoplesData => { 
    let peoples = peoplesData.json(); 
    let nextPage = peoples.next; // https://swapi.co/api/people/?page=2 
    this.peoples = peoples.results; 
}); 

Lorsque j'envoie la demande d'abord, je vais obtenir url pour la prochaine requête (dans cet exemple, l'URL contient dans « nextPage »). J'ai besoin de créer une méthode, qui fera toutes les requêtes, et après chaque requête ajoutera tous les 'résultats' à 'this.peoples'. Je pense, .mergeMap et switchMap ne correspondent pas à cela. Peut-être avez-vous plus d'expérience avec Observable? S'il vous plaît aidez-moi avec cette méthode.

Mise à jour J'ai résolu ce problème avec .expand:

return this.http.get('https://swapi.co/api/people/') 
     .expand(peoplesData => { 
     let peoples = peoplesData.json(); 
     if (peoples.next) { 
      return this.http.get(peoples.next); 
     } else { 
      return Observable.empty(); 
     } 
     }) 
     .map(peoples => peoples.json()); 

Answer 1

Ma solution à l'aide rxjs Rx flatMap:

import {Observable} from 'rxjs/Rx'; 


ngOnInit() { 
    const arrayIds = [2456, 12456, 456, 7899]; 
    this.doUsersRequest(arrayIds); 
} 

doUsersRequest(queryArr, previousObservable = null) { 
     if (queryArr.length) { 
      const url = 'api/users/id/' + queryArr.shift(); 
      let observable = null; 
      if (previousObservable) { 
       observable = previousObservable.flatMap(() => { 
        return this.http.get(url); 
       }); 
      } else { 
       observable = this.http.get(url); 
      } 
      return this.doUsersRequest(queryArr, observable); 
     } else { 
      return previousObservable; 
     } 
    }