We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6840ae0 commit 03bdbf6Copy full SHA for 03bdbf6
lib/core/util.js
@@ -355,15 +355,20 @@ function getSocketInfo (socket) {
355
}
356
357
358
+async function * convertIterableToBuffer (iterable) {
359
+ for await (const chunk of iterable) {
360
+ yield Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk)
361
+ }
362
+}
363
+
364
let ReadableStream
365
function ReadableStreamFrom (iterable) {
366
if (!ReadableStream) {
367
ReadableStream = require('stream/web').ReadableStream
368
369
370
if (ReadableStream.from) {
- // https://github.com/whatwg/streams/pull/1083
- return ReadableStream.from(iterable)
371
+ return ReadableStream.from(convertIterableToBuffer(iterable))
372
373
374
let iterator
0 commit comments