我有一些代码片段如下
var videosNeedFix = Rx.Observable.fromArray(JSON.parse(fs.readFileSync("videoEntries.json"))).share();
videosNeedFix.count().subscribe(function(count){ //subscrption A
console.log(count + " in total");
});
videosNeedFix.subscribe(function(videoEntry){ //subscription B
console.log(videoEntry.id, videoEntry.name, videoEntry.customFields);
});
videoEntries.json 是一个 JSON 序列化的 videoEntry 对象数组。我希望订阅 A 和订阅 B 都能接收由 videosNeedFix observable 发出的数据。
但是,根据控制台日志,只有订阅 A 会收到数据,而订阅 B 不会。如果我交换两个订阅的顺序,只有订阅 B 会看到数据。为什么 observable 只向第一个订阅发送数据?