ネストされたオブザーバを処理する方法

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()で非同期のアクションを行うどのエラーも可能性がありますしないように。あなたはエラー処理と同時実行制御のようなものを行うことができますので、あなたはより良いこれらの呼び出しは、あなたの受信ストリームに埋め込ま持つことができます。

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));