我想我一定是误解了一些基本的东西,因为在我看来,这应该是一个可观察对象的最基本的情况,但在我的一生中,我无法从文档中找出如何做到这一点。
基本上,我希望能够做到这一点:
// create a dummy observable, which I would update manually
var eventObservable = rx.Observable.create(function(observer){});
var observer = eventObservable.subscribe(
function(x){
console.log('next: ' + x);
}
...
var my_function = function(){
eventObservable.push('foo');
//'push' adds an event to the datastream, the observer gets it and prints
// next: foo
}
但是我还没有找到像push
这样的方法。我将其用于单击处理程序,我知道他们有用于此的Observable.fromEvent
,但我正在尝试将其与React一起使用,并且我更希望能够在回调中简单地更新数据流,而不是使用完全不同的事件处理系统。所以基本上我想要的是:
$( "#target" ).click(function(e) {
eventObservable.push(e.target.text());
});
我得到的最接近的方法是使用observer.onNext('foo')
,但这似乎没有实际工作,这是在观察者身上调用的,这似乎是不正确的。观察者应该是对数据流做出反应的东西,而不是改变它,对吗?
我只是不理解观察者/观察者之间的关系吗?
https://stackoverflow.com/questions/33324227
复制相似问题