관찰 대상에서 다른 관측 가능 부분으로 객체 반환

Question

3 개의 다른 REST 끝점에서 데이터를 가져 오려고합니다. 데이터 모델은 주요 데이터로 구성되어 있으며 2 (향후 더 많을 수 있음) 개체로 고급 배열이 있습니다. 각 배열에 지정된 REST 끝점을 기반으로 각 고급 개체에 옵션이있는 배열을 삽입하려고합니다. 모든 것이 작동하고 Observable에서 Object로 반환됩니다. 추가 옵션을 제외하고 Observables로 제공됩니다.

단순화 된 데이터 :, 내 데이터 모델에서

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

I 옵션 [] 배열을 가지고 있지 않습니다

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

음식과 음료 같은 구조가 이름과 ID로 객체로 구성된이 그래서 나는 그것을 수동으로 주입했다. 서비스 :

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