Chaînage d'appels multiples avec foreach loop et Observable

Question

Je souhaite chaîner plusieurs requêtes aux URL que je reçois du tableau. Avant la prochaine chaîne, je veux attendre que la précédente soit terminée. Ce n'est pas grave si le précédent échoue ou non. J'essayais cela avec forkJoin mais je sais que si l'une des requêtes échoue, elle retournera une erreur.

this.dataServers.forEach(dataServer => { 
    observableBatch.push(this.getFoodsByQuery(dataServer.url, query)); 
}); 

return Observable.forkJoin(observableBatch).subscribe(data => { 
    this.searchingServer.next(null); 
    observer.complete(); 
}); 

Je ne sais pas comment faire cela avec flatMap.

Answer 1

Dans votre cas, l'opérateur est adapté concat

Concatène plusieurs observables ensemble en émettant séquentiellement leurs valeurs, une observables après l'autre.

Exemple:

// Batch of requests 
let batch = [ 
    Observable.of(1), 
    Observable.of(2).delay(1500), 
    Observable.throw('Error'), 
    Observable.of(3).delay(300), 
    Observable.throw('Error again'), 
    Observable.of(4).delay(600) 
]; 

// Catch (ignore) error of every request 
batch = batch.map(obs => { 
    return obs.catch(err => Observable.of(err)); 
}); 

// Concat observables 
Observable.concat(...batch).subscribe({ 
    next: v => console.log(v), 
    complete:() => console.log('Complete') 
}); 

sortie: [? Comment forcer à exécuter dans observables séquence]

1 
2 
'Error' 
3 
'Error again' 
4 
'Complete' 

Answer 2

Avez-vous essayé d'utiliser OnErrorResumeNext() avec forkJoin?

return Observable.forkJoin(observableBatch) 
.OnErrorResumeNext() 
.subscribe(data => { 
    this.searchingServer.next(null); 
    observer.complete(); 
});