將2個RxJava Observables轉換爲1個地圖

Question

我有以下場景。我使用Retrofit2從服務器獲取數據。 我想下載Collection<Account>的Account實體，並且對於這些賬戶中的每一個來說，下載Project實體的Collection<Project>。最後我想得到Map<Account, Collection<Project>> accountsWithProjects。

我有以下幾種方法：

1. Observable<Collection<Account>> requestAllAccounts()
2. Observable<Collection<Project>> requestProjectsInfoForTempoAccount(Account accunt)

問：是否可以壓縮或創建這兩個反應流的莫名其妙的foreach迭代，並收集所有的項目到地圖？

如果有幫助，我也可以同步獲取帳戶項目的集合，但無法在主線程上完成，因爲爲Android開發並且必須在主線程上觀察結果。

Answer 1

這裏有一個更好的辦法：

requestAllAccounts() 
.flatMap(account -> requestProjectsInfoForTempoAccount(account), 
    (acccount, projects) -> Pair::of) 
.toMap(Pair::key, Pair::value); 

（擴展到Java 7作爲excercise for the reader）

Answer 2

有你有它：

requestAllAccounts().flatMap(new Func1<Collection<Account>, Observable<Account>>() { 
     @Override 
     public Observable<Account> call(Collection<Account> accountCollection) { 
      return Observable.from(accountCollection); 
     } 
    }).flatMap(new Func1<Account, Observable<Pair<Account, Collection<Project>>>>() { 
     @Override 
     public Observable<Pair<Account, Collection<Project>>> call(Account account) { 
      return Observable.just(account).zipWith(requestProjectsInfoForTempoAccount(account), 
        new Func2<Account, Collection<Project>, Pair<Account, Collection<Project>>>() { 
         @Override 
         public Pair<Account, Collection<Project>> call(Account account, Collection<Project> projects) { 
          return new Pair<Account, Collection<Project>>(account, projects); 
         } 
        }); 
     } 
    }).toList() 
      .flatMap(new Func1<List<Pair<Account, Collection<Project>>>, Observable<Map<Account, Collection<Project>>>>() { 
       @Override 
       public Observable<Map<Account, Collection<Project>>> call(List<Pair<Account, Collection<Project>>> pairs) { 
        Map<Account, Collection<Project>> map = new HashMap<Account, Collection<Project>>(); 
        for (Pair<Account, Collection<Project>> pair : pairs) { 
         map.put(pair.first, pair.second); 
        } 
        return Observable.just(map); 
       } 
      }); 

這到底是怎麼回事？

1. 獲取所有帳戶。
2. 拆分列表爲單一賬戶
3. 調用搜索在單一賬戶項目，並返回Pair<Account, Collection<Project>>
4. 合併的所有對象
5. 變換List<Pair<Account, Collection<Project>>>到Map<Account, Collection<Project>>