Flowableとマージ結果の戻り値に基づいてSingleを取得

Question

私はFlowable<List<Entity>>を返すメソッドを呼び出しています。このリストのすべてのエンティティについて、関連するSingle<AnotherEntity>を返すメソッドを呼び出す必要があります。 EntityとAnotherEntityは、1つのオブジェクトにマージされ、すべてがリストに返されます。

return playerRepository.getAllPlayers() 
    .flatMapIterable(players -> players) 
    .map(player -> player.apiId) 
    .flatMapSingle(apiId -> statsRepository.getGameLog(apiId)) 
    .subscribe(
      stats -> { statsEntries.add(stats); } 
    ); 

どのように私は私の要件を満たしてきれいな溶液に、これを変更することができます？私は今、このようになります持っているもの

Answer 1

あなたは本当にその中間map()を必要としない、あなたは、元のエンティティが含まれているペアに第2のマップの結果をマッピングすることができます

return playerRepository.getAllPlayers() 
    .flatMapIterable(players -> players) 
    .flatMapSingle(player -> 
     statsRepository.getGameLog(player.apiId) 
     .map(log -> new BothEntities(player, log)) 
    ) 
    .toList() 
    .subscribe(
     allEntities -> { /* handle the list */ } 
    );