如何在代码中稍后创建observable并生成下一个值?我希望能够通过其他异步事件从代码的不同部分调用onNext。将观察者存储在全局变量中并稍后使用
这是我已经尽力了,这是不行的:
var Rx = require('rx');
var GlobalObserver;
var source = Rx.Observable.create(observer => {
GlobalObserver = observer;
});
var subscription = source.subscribe(
x => console.log('onNext: %s', x),
e => console.log('onError: %s', e),
() => console.log('onCompleted')
);
//...later in the code, as a result of another async event:
GlobalObserver.onNext(someData);
...
GlobalObserver.onNext(someOtherData);
这绝对应该是一个评论,不是答案。 – DavidDomain