fix: detect node stream with hasOwnProperty (#33)

* fix: destroy the stream reguardless * chore: detect PassThrough stream with source.hasOwnProperty * chore: linting
ipfs · Apr 8, 2020 · 1c1d894 · 1c1d894
1 parent 845b8c3
commit 1c1d894
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/src/http.js b/src/http.js
@@ -263,15 +263,13 @@ const ndjson = async function * (source) {
 const streamToAsyncIterator = function (source) {
   if (isAsyncIterator(source)) {
     // Workaround for https://github.com/node-fetch/node-fetch/issues/766
-    if (source.writable && source.readable) {
+    if (Object.prototype.hasOwnProperty.call(source, 'readable') && Object.prototype.hasOwnProperty.call(source, 'writable')) {
       const iter = source[Symbol.asyncIterator]()
 
       const wrapper = {
         next: iter.next.bind(iter),
         return: () => {
-          if (source.writableEnded) {
-            source.destroy()
-          }
+          source.destroy()
 
           return iter.return()
         },