fixup

nodejs · Aug 17, 2021 · 7c9b565 · 7c9b565
1 parent 0cd0eee
commit 7c9b565
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/lib/fetch/util.js b/lib/fetch/util.js
@@ -135,6 +135,11 @@ function toWebReadable (iterable) {
     ReadableStream = require('stream/web').ReadableStream
   }
 
+  if (ReadableStream.from) {
+    // https://github.com/whatwg/streams/pull/1083
+    return ReadableStream.from(iterable)
+  }
+
   const iterator = iterable[Symbol.asyncIterator]()
 
   return new ReadableStream({
@@ -151,7 +156,7 @@ function toWebReadable (iterable) {
     async cancel (reason) {
       await iterator.return()
     }
-  })
+  }, 0)
 }
 
 // https://w3c.github.io/webappsec-referrer-policy/#set-requests-referrer-policy-on-redirect