ネストしたObservablesを平坦化する

Question

私はネストされた観測可能な地獄で立ち往生しており、手で行うことができます。

Iは、次のコードブロック

return this.findUser(term).map(users => { 
    return users.map(user => this.getLastLogin(user.user_id).map(last_login => { 
    user.last_login = last_login; 
    return user; 
    })); 
}); 

findUser戻りObservable<User[]>とgetLastLogin戻りObservable<number>を有します。

私は基本的にユーザーのリストを取得し、別の値の情報でこれを更新することを望んでいます。

今すぐ上のコードは<Observable<Observable<User>[]>を返しています。

mapをflatMapに置き換えることができると考えましたが、これはオブジェクトを<Observable<Observable<User>>に変えます。

RxJSのドキュメントは少し解読しにくいので、switch、forkJoinまたはflatMapの組み合わせが私に必要なものを手に入れてくれるかどうかはわかりません。

私はObservable<User[]>を返すことを望んでいます。誰かが私を正しい方向に向けることができますか？

Answer 1

実は、あなたはこれを行うにはforkJoin()もswitch()を必要としません。

通常、別の非同期呼び出しによってユーザーのアレイ内の各ユーザーを更新する必要があります。

私はこのようにそれを行うだろう：

var source = findUser('term') 
    .mergeAll() 
    .mergeMap(user => getLastLogin(user.user_id) 
     .map(last_login => { 
      user.last_login = last_login; 
      return user; 
     }) 
    ) 
    .toArray(); 

source.subscribe(val => console.log(val)); 

オペレータmergeAll()単一の観測に観察可能な高次に変換します。この場合、すべてのユーザーの配列を取り、1つずつ再発行します。その後、mergeMap()はlast_loginの日付で更新されたユーザーを放出します。最後に私はtoArray()を使用して、単一のユーザーを1つの大きな配列に変換しました。この配列は全体として放出されます（単一のユーザーを放出する場合はこの演算子を削除できます）。あなたがreturn users.map(...)を使用したとき、あなたが観察を返しアレイとないmap() RxJSからを返すArray.map()を使用していたことを

は注意してください。私は単一のオブジェクトで作業するのは、通常、オブジェクトの配列で簡単だと思います。

はライブデモを参照してください：https://jsbin.com/naqudun/edit?js,console

はこれがコンソールに出力します。

[ { name: 'foo', 
    user_id: 42, 
    last_login: 2016-11-06T10:28:29.314Z }, 
    { name: 'bar', 
    user_id: 21, 
    last_login: 2016-11-06T10:28:29.316Z } ] 

Answer 2

一つの解決策は、参加して、ユーザーにgetLastLoginへの呼び出しの結果をマッピングするためにforkJoinを使用することです：

// forkJoin will return Observable<User[]>, so use switchMap. 

return this.findUser(term).switchMap(users => Observable.forkJoin(

    // Map the array of users to the array of observables to be joined. Use 
    // first to ensure the observables complete. 

    users.map(user => this.getLastLogin(user.user_id).first()), 

    // Use forkJoin's selector to add the last_login to each user and return 
    // the users. 

    (...logins) => { 
    users.forEach((user, index) => { user.last_login = logins[index]; }); 
    return users; 
    } 
));