为什么 Rxjs publishReplay(1).refCount() 不重播？答案

【问题标题】：Why does Rxjs publishReplay(1).refCount() not replay?为什么 Rxjs publishReplay(1).refCount() 不重播？
【发布时间】：2017-06-16 00:18:15
【问题描述】：

为什么 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)});

&lt;script src="http://reactivex.io/rxjs/user/script/0-Rx.js"&gt;&lt;/script&gt;

预期输出：

timely subscribe: 1
late subscriber: 1

实际输出

timely subscriber: 1

【问题讨论】：

标签： javascript rxjs rxjs5

【解决方案1】：

发生这种情况是因为在您调用 a.next(1) 时，publishReplay(1) 尚未订阅其源 Observable（在本例中为主题 a），因此内部 ReplaySubject 不会收到值 @987654328 @。

在 RxJS 5 中，运算符之间的实际订阅发生在您订阅链的末尾时，在本例中为 b.subscribe(...)。见：

直到你调用 subscribe() 之前，操作符都是链式的，这要归功于 lift() 方法，它只接受一个操作符实例并将其分配给新的 Observable。如您在上面两个链接中所见，operator.call() 方法稍后在订阅时调用。见：

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

【讨论】：

但是如果 a 本身被定义为 ReplaySubject 你会看到这个值:-)

【解决方案2】：

您的第一个订阅者订阅了a，因为refCount 在至少有1 个订阅者时首先激活流（其中没有订阅者，因为不是b，而是a 订阅了），它不是直到你最后一次找到为止。

a = new Rx.Subject(); 
b = a.publishReplay(1).refCount(); 

b.subscribe(function(x){console.log('timely subscriber:',x)});
a.next(1); 
b.subscribe(function(x){console.log('late subscriber:',x)});

&lt;script src="https://unpkg.com/rxjs/bundles/Rx.min.js"&gt;&lt;/script&gt;

【讨论】：