RXJSフィルターが別の観測にあります

Question

私のコードでは、MS Graphからユーザーリストを取得していますが、これはすべてのユーザーをリストしています。私は指定されたグループのメンバーであるユーザーだけを出したい。だから私は、フィルタを設定している：

private loadUsers() { 
    console.log(`Loading users...`); 
    this.graph.get$(`users`) 
     .map(resp => resp.json().value) 
     .flatMap(user => user) 
     .do(user => { 
      console.log(`Got user: ${user['displayName']}`); 
     }) 
     .filter(user => { 
      // we only want users who are members of the TrackerContact group 
      const userId: string = user['id']; 
      console.log(`Checking user ${userId}`); 
      return this.userIsTrackerContact(user); // <<= PROBLEM HERE! 
     }) 
     .subscribe(_ => { 
      console.log(`Completed user fetch!`); 
     }); 
} 

問題は、ユーザーがメンバーである、私は戻ってMS Graphに別のREST呼び出しを行う必要がありますどのようなグループを見つけるためにある：

private userIsTrackerContact(user): Observable<boolean> { 
    // get the groups this user is a member of 
    return this.graph.get$(`users/${user['id']}/memberOf`) 
     .map(resp => resp.json().value) 
     .do(groups => { 
      console.log(`${user['displayName']} is a member of ${groups.length} groups:`); 
      groups.forEach((group, idx) => { 
       console.log(` [${idx+1}]: ${group['displayName']}`); 
      }) 
     }) 
     .map(groups => { 
      const found = groups.find((group) => group['id'] === this.authConfig.azureGroups.trackerContact) 
      return !isUndefined(found); 
     }) 
} 

それは、 filterに別の観測に基づいて観測可能であると私には思われません。述語テストは単純な真偽テストでなければなりません。

Observableを別のObservableの結果に基づいてフィルタリングするにはどうすればよいですか？

Answer 1

.concatAll（）が良いかもしれない：

this.graph.get$(`users`) 
    .map(resp => resp.json().value) 
    .flatMap(user => user) 
    .do(user => { 
     console.log(`Got user: ${user['displayName']}`); 
    }) 
    .filter(user => { 
     // we only want users who are members of the TrackerContact group 
     const userId: string = user['id']; 
     console.log(`Checking user ${userId}`); 
     return this.userIsTrackerContact(user); // <<= PROBLEM HERE! 
    }) 
    .concatAll() 
    .subscribe(...) 

私はあなたが非同期観測はその後、フィルタmergeすることができるはずと信じています。

Rx.Observable.merge(this.graph.get$(`users`) 
    .map(resp => resp.json().value) 
    .flatMap(user => user) 
    .do(user => { 
     console.log(`Got user: ${user['displayName']}`); 
    }) 
    .map(user => { 
     // we only want users who are members of the TrackerContact group 
     const userId: string = user['id']; 
     console.log(`Checking user ${userId}`); 
     return this.userIsTrackerContact(user); // <<= PROBLEM HERE! 
    })) 
    .filter(x => x) 
    .subscribe(_ => console.info('success')); 

述語を変更するには、ユーザーisGroupMemberのプロパティを設定します。その後、filter(x => x.isGroupMember)。次に、subscribeメソッドにユーザーオブジェクトがあります。