RxJs - 購読対象の件名から次の件を呼ぶ

Question

私はRxを初めて使い、Httpでトークン管理の作業をしています。私はトークンを追跡し、このトークンがすべてのアウトバウンドHTTPリクエストのヘッダーに追加されるという考えがあります。

コードはそうのようになります。観測可能な要求から返される

const request = (name, token, time) => { 
    console.log('attempt ' + name + ' with token ' + token); 
    return Rx.Observable.timer(time) 
     .do(() => { 
     console.log('sent ' + name + ' with token ' + token); 
     }) 
     .mapTo({ newToken: 'baz' }) // token baz arrives 
     .do(r => { 
     console.log('response for ' + name + ' received'); 
     }); 
}; 

const token$ = new Rx.ReplaySubject(1); 

token$.switchMap(token => request('request1', token, 0)) 
    //.do(rs => { token$.next(rs.newToken); }) // fails, causes a loop 
    .subscribe(
     // (rs) => { token$.next(rs.newToken); } // also fails with loop 
    ); 

token$.switchMap(token => request('request2', token, 1000)) 
    .subscribe(); 

// emit a token 

token$.next('bar'); 

// but how do I ensure 'request2' is sent with token 'baz' ? 

私の質問は、どのように私はbazとReplaySubjectを更新することができますか？

私はそうのようrequest1でdoからnextを呼び出してみました：

token.switchMap(token => request('request1', token, 0)) 
    .do(rs => { token.next(rs.newToken); }) 
    .subscribe(); 

しかし、これはループにそれを送り、request1がトークンbazで繰り返されます。件名のnextをdoから購読されたObservableでこのように呼び出すことはできますか？私はそれがいくつかのRx契約や何かに違反しているのだろうかと思っています。

私はまた、このようrequest1を試してみました：

token.switchMap(token => request('request1', token, 0)) 
    .subscribe(rs => { token.next(rs.newToken); }); 

しかし、同じループが発生します。おそらく私はnextを私がswitchMapである事に呼んでいるからでしょうか？

どのように私はこれを動作させることができますか？ありがとう！その後、再利用されるべきである、私はあなたが右のこのmap関数は、実際にいくつかの外部コールを行うと、トークンを返すことになっている理解していれば

jsbin here

Answer 1

OK？そして、return { newToken: 'baz' };はちょうど嘲笑された結果です。

token.next('bar')は、replaySubjectに新しいトークンを追加するだけでなく、新しい要求も発生させるという問題があります。

newRequestSubjectをtokenSubjectから分割します。そうすれば、新しいトークンを発射することなく新しいトークンをプッシュすることができます。これは、すでに気付いたように無限ループに終わることになります。

その後、requestSubjectを準備するためにnewRequestSubject.withLatestFrom(tokenSubject).switchMap(request).subscribe()を使用して要求をプッシュするnewRequestSubject.next(200, 'request1')を呼び出すことができます。

tokenSubjectのreplaySubjectをbehaviorSubjectに置き換えることもできるので、作成時に最初のトークンを渡すことができます。

requestの中には、tokenSubject.next()を呼び出してトークンを更新できます。

副題として、件名を一括して除外することは、たとえばmergeScanなど、以前のリクエストの結果を次のものに送ることができますすぐに理解するのが少し難しい。

newRequestSubject.mergeScan(request, initialToken); 

は