Promise.all comportamento con RxJS Observables?

Question

In Angular 1.x a volte devo fare più richieste http e fare qualcosa con tutte le risposte. Vorrei lanciare tutte le promesse in un array e chiamare Promise.all(promises).then(function (results) {...}).

Le 2 migliori pratiche angolari sembrano indicare l'utilizzo di Observable di RxJS in sostituzione delle promesse nelle richieste http. Se ho due o più oggetti osservabili diversi creati da richieste http, è un equivalente a Promise.all()?

Answer 1

L'alternativa più semplice per emulare Promise.all consiste nell'utilizzare l'operatore forkJoin (inizia tutti osservabili in parallelo e uniscono i loro ultimi elementi):

• documentation
• collegamento: cf. RxJS: concat three promises, distinguish results

Un po 'fuori portata, ma in caso aiuta, in materia di promesse concatenamento, è possibile utilizzare un semplice flatMap: Cf. RxJS Promise Composition (passing data)

Answer 2

forkJoin funziona bene, ma preferirei combineLatest poiché non è necessario preoccuparsi di prendere l'ultimo valore di osservabili. In questo modo, puoi semplicemente essere aggiornato ogni volta che uno di essi emette anche un nuovo valore (ad esempio, recuperi su un intervallo o qualcosa del genere).

Answer 3

Su reactivex.ioforkJoin in realtà punta a Zip, che ha fatto il lavoro per me:

let subscription = Observable.zip(obs1, obs2, ...).subscribe(...);