Rx.js，使用未定义调用订阅

Question

我正在使用 Rx.js 将 AJAX 调用的结果流式传输到多个单元。

但是当订阅 MapObserver 的观察者超过一个时，我遇到了问题。当第一个订阅者将始终获得正确的数据时，其余的将变得不确定。

this.observable        = new Rx.Subject();

observeMap = this.observable
  .map(createMarker.bind(this));

var s1 = observeMap.subscribe(console.log.bind(console, 1));

var s2 = observeMap.subscribe(console.log.bind(console, 2));

请指教，谢谢！

Answer 1

我刚刚为我的问题找到了解决方案，为了在少数订阅者之间共享一个可观察对象，您可以使用 share 方法。

this.observable        = new Rx.Subject();

observeMap = this.observable
  .map(createMarker.bind(this))
  .share();

var s1 = observeMap.subscribe(console.log.bind(console, 1));

var s2 = observeMap.subscribe(console.log.bind(console, 2));

Rx.js，使用未定义调用订阅

Rx.js, Subscribe is called with undefined

javascript

reactive-programming

node.js

rxjs