ループでネストされたobservable内で条件付きでforkJoin observablesを呼び出す

Question

タイルの配列を取得しています。その配列の一部には配列があります。設定を持つものは、オプションの配列（optionオブジェクトを含む）またはrestURLを指すoptionUrlのいずれかを持つ可能性があります。 これらのオプションを各タイルに追加するには、設定とoptionUrlがありますか？ flatMapとforkJoinを試しましたが、optionsUrlのリクエストが完了しないようです。また、私はmergeMapを試してみました。

どのようにすれば効果がありますか？ここで

はoptionUrlと例のタイル構造です：

{ 
    id: "superTile", 
    name: "Super Tile", 
    configurations: [ 
     { 
     param: "shopId", 
     optionsUrl: "rest/shops" 
     }, 
     { 
     param: "sortOrder", 
     option: [ 
     { 
      id: "Newest", 
      text: "PROD_YEAR-DESC" 
     }, 
     { 
      id: "Rank", 
      text: "RANKING-DESC" 
     }, 
     ] 
     } 
     ] 
    } 

ここに私のコンポーネントです：

ngOnInit(){ 
this._myService.getAllTiles() 
    .subscribe((tiles: Tiles[]) => { 
     this.tiles = tiles 
    }) 
} 

マイサービス：

getAllTiles(): Observable<any>{ 
    return this._http 
     .get(this._tilesUrl) 
     .map((result) => result.json().data) 
     .flatMap((tiles) => { 

      tiles.map((tile) => { 
       if (tile.configurations) { 
        return Observable.forkJoin(
         tile.configurations.map((config) => { 
          if(config.optionsUrl) { 
           console.log(config); 
            return this._http.get(config.optionsUrl) 
             .map((result) => { 
              let optionArray = []; 
              config['option'] = optionArray; 
              let jsonObj = result.json(); 
              let newOptions = jsonObj.data; 

              console.log(newOptions); 

              config['option'].push(newOptions); 
              return config; 
             }) 
          } else { 
           return Observable.of(config); 
          } 
         }) 
        ) 
       } else { 
        return Observable.of(tiles) 
       } 
      }); 
      return Observable.of(tiles); 
      }) 
      } 

Answer 1

問題は、あなたのflatMap方法にあります。配列をループするのにjs mapを使用していますが、mapが作成する返された配列を使用していません。 Observable.of(tiles)を毎回flatMapに返すので、毎回値が購読されます。代わりにtiles.mapが返す配列を返すべきです

.flatMap((tiles) => { 
    let tilesObservables$ = tiles.map(// rest of map code); 

    return Observable.forkJoin(tilesObservables$); 
});