ReplaySubjectから最後の値を取得するにはどうすればよいですか？

Question

以下は、私が何をしようとしているかを説明するスニペットです。私のアプリケーションでは、全体を通して使用されているreplaysubjectがあります。特定の時点で、私は最後にsubjectから放出された値を取得したいが、lastはReplaySubjectでは機能しないようだ。

const subject = new Rx.ReplaySubject(); 

subject.next(1); 
subject.next(2); 
subject.next(3); 
subject.next(4); 

subject.subscribe(num => console.log(num)); 

var lastObserver = subject.last(); 
lastObserver.subscribe(num => console.log('last: ' + num)); 

FIDDLE

上記のコードはlastObserverのために何かを発射するが、うまく作品を加入していません。

Answer 1

あなたの混乱は、.last()オペレータがどのように働くことになっているのでしょうか？

.last()は、ストリームが完了するのを待ってから、ストリームが終了する前に放出された最後の値を返します。そのためにはストリームを終了する必要があります。

あなたのlastObserverは、被験者が完了するとすぐに放出されると思います。

const subject = new Rx.ReplaySubject(); 

subject.next(1); 
subject.next(2); 
subject.next(3); 
subject.next(4); 

subject.subscribe(num => console.log(num)); 
subject.complete(); // end your stream here 
var lastObserver = subject.last(); 
lastObserver.subscribe(num => console.log('last: ' + num)); 

あなたが最後にあなたのストリームをしたくないが、あなたは、加入者が加入する前に放出された最後の値を受信したくない場合は、このユースケースのために設計された、BehaviorSubjectのために達することを検討してください。