RxJs 5 share()运算符是如何工作的？
RxJs 5 share()运算符是如何工作的？
提问于 2016-02-02 06:34:44
我不是100%清楚RxJs 5 share()操作符是如何工作的，请看这里的latest docs。问题here的Jsbin。
如果我创建一个包含0到2的序列的可观察值，每个值被一秒隔开：
var source = Rx.Observable.interval(1000)
.take(5)
.do(function (x) {
console.log('some side effect');
});如果我为这个可观察对象创建两个订阅者：
source.subscribe((n) => console.log("subscriptor 1 = " + n));
source.subscribe((n) => console.log("subscriptor 2 = " + n));我在控制台中得到了这个：
"some side effect ..."
"subscriptor 1 = 0"
"some side effect ..."
"subscriptor 2 = 0"
"some side effect ..."
"subscriptor 1 = 1"
"some side effect ..."
"subscriptor 2 = 1"
"some side effect ..."
"subscriptor 1 = 2"
"some side effect ..."
"subscriptor 2 = 2"我以为每个订阅都会订阅相同的可观察对象，但事实似乎并非如此！这就像订阅行为创建了一个完全独立的可观察对象！
但如果将share()运算符添加到源可观测对象中：
var source = Rx.Observable.interval(1000)
.take(3)
.do(function (x) {
console.log('some side effect ...');
})
.share();然后我们得到这个：
"some side effect ..."
"subscriptor 1 = 0"
"subscriptor 2 = 0"
"some side effect ..."
"subscriptor 1 = 1"
"subscriptor 2 = 1"
"some side effect ..."
"subscriptor 1 = 2"
"subscriptor 2 = 2"这就是我在没有share()的情况下所期望的。
这里发生了什么，share()操作符是如何工作的？每个订阅都会创建一个新的观察链吗？
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/35141722
复制相关文章
相似问题