为什么 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(主题 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()
方法稍后会在订阅时调用。见:
关于javascript - 为什么 Rxjs publishReplay(1).refCount() 不重播?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41942723/