我不是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()
操作符是如何工作的?每个订阅都会创建一个新的观察链吗?
https://stackoverflow.com/questions/35141722
复制相似问题