javascript – 为什么Rxjs publishReplay(1).refCount()不重播?

为什么publishReplay(1).refCount()不重播后期订阅者的最后一个值?
a = new Rx.Subject(); 
b = a.publishReplay(1).refCount(); 

a.subscribe(function(x){console.log('timely subscriber:',x)});
a.next(1); 
b.subscribe(function(x){console.log('late subscriber:',x)});
<script src="http://reactivex.io/rxjs/user/script/0-Rx.js"></script>

预期产量:

timely subscribe: 1
late subscriber: 1

实际输出

timely subscriber: 1

解决方法

发生这种情况是因为在您调用a.next(1)时,publishReplay(1)尚未订阅其源Observable(在这种情况下为Subject a),因此内部ReplaySubject将不会收到值1.

在RxJS 5中,操作符之间的实际订阅发生在链的末尾,即本例中的b.subscribe(…).看到:

> https://github.com/ReactiveX/rxjs/blob/master/src/operator/multicast.ts#L63
> https://github.com/ReactiveX/rxjs/blob/master/src/Observable.ts#L96

调用subscribe()之前,运算符由于lift()方法而被链接,该方法只接受运算符的实例并将其分配给新的Observable.您在上面的两个链接中可以看到的operator.call()方法稍后在订阅调用.看到:

> https://github.com/ReactiveX/rxjs/blob/master/src/Observable.ts#L67

相关文章

前言 做过web项目开发的人对layer弹层组件肯定不陌生,作为l...
前言 前端表单校验是过滤无效数据、假数据、有毒数据的第一步...
前言 图片上传是web项目常见的需求,我基于之前的博客的代码...
前言 导出Excel文件这个功能,通常都是在后端实现返回前端一...
前言 众所周知,js是单线程的,从上往下,从左往右依次执行,...
前言 项目开发中,我们可能会碰到这样的需求:select标签,禁...