理解 share() RxJS 操作符以及 Rx.Observable.ajax

Question

我正在尝试了解 RxJS 5 share() 运算符的行为。

根据教程和文档，share() 将冷的 observable 变成热的。

我正试图看到这一点。这是我尝试过的：

const search$ = Rx.Observable.ajax('https://www.googleapis.com/books/v1/volumes?q=javascript').share();

然后我第一次订阅：

search$.subscribe(console.log);

我从开发工具中看到发出了网络请求：

 Request URL:https://www.googleapis.com/books/v1/volumes?q=javascript

然后在重新运行相同的订阅时：

search$.subscribe(console.log);

我注意到另一个网络请求也发出了。

有人可以解释为什么share() 运算符会显示这种行为吗？我原以为只会发出一个网络请求...

P.S. 使用 xxx.publishLast().refCount(); 而不是 xxx.share(); 可以完成这项工作，但我主要关心的是了解上述上下文中的 share() 行为。

Answer 1

share 是publish().refCount() 的快捷方式。 refCount-part 表示，只要至少有 1 个订阅者，流就是热/共享的 - 但是，当没有订阅者时，它会被重置/冷。当您的ajax-requests 完成时，流完成，并且在流完成后，任何订阅者都会自动取消订阅-> 将流的订阅者设置为 0 并因此重置流-这就是您遇到第二个网络的原因-寻求任何未来的订阅。

为什么这适用于publishLast().refCount()？ - 使用publishLast()，你会得到一个永远不会完成的流，因此没有订阅者会自动取消订阅，并且流永远不会被重置。

---

对于缓存 HTTP 响应，您使用 publishLast().refCount() 的方法是完全有效的。