RxJava：別の観測可能な結果を​​待つ

Question

現在のものを変換する際に観察可能な別の結果を待つ方法はありますか？

ユーザーIDのリスト（userIdsList）があり、マップに変換する必要があります。マップキーはuserIdで表され、値はbooleanで、userIdがregUsersを含むかどうかを示します。

return Observable 
    .<List<Long>>from(userIdsList) 
    .groupBy(id -> id, id -> regUsers.contains(id)); //PROBLEM: regUsers is Observable<List<Long>> 

Answer 1

多少畳み込まれた解決策。

 List<Long> ids = Arrays.asList(1L, 2L, 3L); 
     Observable<List<Long>> regUsers = Observable.just(Arrays.asList(1L, 2L)).cache(); 

     Observable<Long> idsStream = Observable.from(ids).cache(); 
     Observable<Boolean> containsStream = idsStream 
      .concatMap(id -> regUsers.map(regList -> regList.contains(id))); 

     idsStream.zipWith(containsStream, (Func2<Long, Boolean, Pair>) Pair::new) 
      .toMap(Pair::getLeft, Pair::getRight).subscribe(System.out::println); 


    private static class Pair<K, V> { 

    private final K left; 
    private final V right; 

    public Pair(K left, V right) { 
     this.left = left; 
     this.right = right; 
    } 

    public K getLeft() { 
     return left; 
    } 

    public V getRight() { 
     return right; 
    } 
}