如何处理嵌套的可观察对象

Question

这段代码对我有用，但我想知道这是否是处理嵌套订阅的更好方法。我正在获取一个我需要循环并在另一个 http 调用中使用的数组。这样有效率吗？

this.storeService.fetchStores(this.currentCoordinates).subscribe(nearestStores => {
           nearestStores.forEach(store => {
                this.stockService.fetchStockResults(ean, store.id).subscribe(stock => {
                    this.stockResults.push({
                        storeObject: store,
                        ean: stock.ean,
                        ranged: stock.ranged,
                        inStock: stock.quantity > 0 ? true : false
                    }
                    );
                });
            });
        });

Answer 1

最好不要在 .subscribe() 中执行异步操作，这也可能会出错。您最好将这些调用嵌入到您的 Rx 流中，这样您就可以进行错误处理和并发控制之类的事情：

this.storeService.fetchStores(this.currentCoordinates)
  .mergeMap(_ => _) /* emit all values from the stores array as separate values in the rx stream */
  .mergeMap(
    store => this.stockService.fetchStockResults(store.ean, store.id))
      .catch(err => Rx.Observable.of({ ean: -1, range: false, quantity: -1})),
    (store, stock) => ({
                        storeObject: store,
                        ean: stock.ean,
                        ranged: stock.ranged,
                        inStock: stock.quantity > 0 ? true : false
                    }),
    10 /* concurrency; how many in-flight requests do you want?*/
  )
  .toArray()
  .subscribe(stockResults => console.log(stockResults));

如何处理嵌套的可观察对象

How to handle nested observables

rxjs5

angular