我对Rxjs很陌生,并试图在其中实现以下工作流:
终止对第一请求的订阅,启动对第二请求的订阅。//下面的代码位于my menu var callAction = function(someParameters) {返回Rx.Observable.create(函数(观察者)){ var订阅=true的函数事件中;myHttpApi.someActio
好了,我是一个完全的Rx初学者,不幸的是,我对js和js中的流也是非常陌生的。我正在使用这个连接到twitters流api,并接收带有tweet的json对象。到目前为止,我已经有了以下代码
var TwitterStream = require('twitter-stream-api'),streams,尤其是RxJS。我已经尝试了我能想到的所有方法来创建一个可观察对象。Rx.