如何从ReplaySubject获取最后一个值？

Question

下面是描述我想要做的事情的片段。在我的应用程序中，我有一个遍及使用的replayysubject。在某个时刻，我想获得主题发出的最后一个值，但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，这是专为这种使用情况。