Merge b8d2ba8 into 2a13064

tusharmath · Mar 18, 2018 · b1f7085 · b1f7085
2 parents 2a13064 + b8d2ba8
commit b1f7085
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/Request.js b/src/Request.js
@@ -13,13 +13,15 @@ export const ev = R.curry(($, event) =>
 )
 
 export const RequestParams = R.curry((request, params) => {
-  return O.create(observer =>
-    request(params)
+  return O.create(observer => {
+    const req = request(params)
       .on('data', message => observer.onNext({event: 'data', message}))
       .on('response', message => observer.onNext({event: 'response', message}))
       .on('complete', () => observer.onCompleted())
       .on('error', error => observer.onError(error))
-  )
+
+    return () => req.abort()
+  })
 })
 
 export const Request = R.curry((request, params) => {