オブジェクトを別の観測対象の中に観測可能から返す

Question

3つの異なるREST終点からデータを取得しようとしました。データモデルは主データで構成されており、2つのオブジェクト（将来的にはより多くのオブジェクトがあります）を持つ高度な配列を持ちます。私は、それぞれに指定されたRESTエンドポイントに基づいて、高度なオブジェクトのそれぞれにオプションを持つ配列を挿入したいと考えています。すべてが機能し、オブジェクトとしてObservableから返されます。Observablesとして追加されるオプションは例外です。

簡易データ：

{ 
simple: { 
    param: "searchQuery", 
}, 
advanced: [ 
    { 
    param: "food", 
    optionsModel: { 
    url: "http://address.com/food",  
    } 
    }, 
    { 
    param: "drinks", 
    optionsModel: { 
    url: "http://address.com/drinks", 
    } 
    } 
    ] 
} 

食べ物や飲み物は、名前とIDとオブジェクトから成る同じ構造を有する：私のデータモデルでは

{ 
    data: [ 
    { 
    name: "DR1", 
    id: 1 
    }, 
    { 
    name: "DR2", 
    id: 1 
    }, 
    ... 
    ] 
} 

を私はオプション[]配列を持っていません、私はそれを手動で注入します。サービス：

searchConfiguration$: Observable<SearchConfiguration> = this.http 
    .get(this._configURL) 
    .map((config) => { 
     let configuration = config.json(); 
     let advancedArray = configuration.advanced; 

     if(advancedArray) { 
     advancedArray.forEach(advanced => { 
      advanced.options = []; 
      advanced.options = this.http.get(advanced.optionsModel.url) 
      .map((r: Response) => r.json().data 
     }) 
     } 
    return configuration; 
    }) 

親コンポーネント：

getSearchConfig() { 
    this.searchConfiguration$ = this._bundlesService.searchConfiguration$; 
} 

それから私は、観察可能に加入するには、HTMLで非同期パイプを持っています。私のオプションは、実際の配列としてではなくストリームとして拡張されたものにすることができますか？

編集 - ソリューション

おかげでマーティンの答えに、解決策は、両方のストリームを平らにし、私はそれが、私がテストしていない

searchConfiguration$: Observable<SearchConfiguration> = this.http 
    .get(this._configURL) 
    .map((config) => config.json()) 
    .concatMap((configuration) => { 
     let observables = configuration.advanced.map((advanced) => { 
     return this.http.get(advanced.optionsModel.url) 
      .map((r: Response) => r.json().data) 
      .concatMap((options) => advanced.options = options) 
     }); 
    return Observable.forkJoin(observables, (...options) => { 
     return configuration; 
    }) 
    }); 

Answer 1

forkJoin（）で最後にそれらを接続することです

searchConfiguration$: Observable<SearchConfiguration> = this.http 
    .get(this._configURL) 
    .map((config) => config.json()) 
    .concatMap(configuration => { 
    var observables = configuration.advanced.map(advanced => { 
     return this.http.get(advanced.optionsModel.url) 
     .map((r: Response) => r.json().data); 
    }); 

    return Observable.forkJoin(observables, (...options) => { 
     configuration.options = options; 
     return configuration; 
    }); 
    })