RxJS SuperAgent

gistfile1.js

var toObservable = request => Rx.Observable.create(observer => {
  var req = request.end((err, res) => {
    if(err) {
      observer.onError(err)
    } else {
      observer.onNext(res)
      observer.onComplete()
    }
  })
  return Rx.Disposable.create(() => {
    req.abort()
  })
})