How can I create an observable and generate the next value later in the code? I would like to be able to call onNext from different parts of the code as a result of other async events.
This is what I have tried, which doesn't work:
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);
See Question&Answers more detail:os