Tag: 被动编程的

RxJS:我将如何“手动”更新Observable?

我认为我必须误解一些基本的东西,因为在我看来,这应该是一个可观察的最基本的情况,但是对于我的生活,我无法弄清楚如何从文档中做到这一点。 基本上,我想能够做到这一点: // 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 } 但是我一直没能find像push这样的方法。 我使用这个为一个点击处理程序,我知道他们有Observable.fromEvent的,但我试图用它与React,我宁愿能够简单地更新数据stream在callback,而不是使用一个完全不同的事件处理系统。 所以基本上我想这个: $( "#target" ).click(function(e) […]