fix: restore old stream conversion

ipfs · Jan 11, 2023 · d7495e4 · d7495e4
1 parent f70d49f
commit d7495e4
Showing 1 changed file with 17 additions and 1 deletion.
diff --git a/src/http.js b/src/http.js
@@ -282,7 +282,23 @@ const fromStream = (source) => {
   }
 
   if (isWebReadableStream(source)) {
-    return browserReableStreamToIt(source)
+    const reader = source.getReader()
+    return (async function * () {
+      try {
+        while (true) {
+          // Read from the stream
+          const { done, value } = await reader.read()
+          // Exit if we're done
+          if (done) return
+          // Else yield the chunk
+          if (value) {
+            yield value
+          }
+        }
+      } finally {
+        reader.releaseLock()
+      }
+    })()
   }
 
   throw new TypeError('Body can\'t be converted to AsyncIterable')