From c68b11e8cbf493723d0b2e029fe6e10d1fe7e83d Mon Sep 17 00:00:00 2001 From: Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> Date: Sat, 19 Nov 2022 23:05:03 -0800 Subject: [streams] Fix exception in streams with 1 item that sometimes occurred --- src/bun.js/builtins/js/ReadableStreamDefaultReader.js | 17 +++++++++++++++-- 1 file changed, 15 insertions(+), 2 deletions(-) (limited to 'src/bun.js/builtins/js/ReadableStreamDefaultReader.js') diff --git a/src/bun.js/builtins/js/ReadableStreamDefaultReader.js b/src/bun.js/builtins/js/ReadableStreamDefaultReader.js index 9430a1037..4671f1458 100644 --- a/src/bun.js/builtins/js/ReadableStreamDefaultReader.js +++ b/src/bun.js/builtins/js/ReadableStreamDefaultReader.js @@ -96,12 +96,25 @@ function readMany() if (length > 0) { var outValues = @newArrayWithSize(length); if (@isReadableByteStreamController(controller)) { - for (var i = 0; i < length; i++) { + + { + const buf = values[0]; + if (!(@ArrayBuffer.@isView(buf) || buf instanceof @ArrayBuffer)) { + @putByValDirect(outValues, 0, new @Uint8Array(buf.buffer, buf.byteOffset, buf.byteLength)); + } else { + @putByValDirect(outValues, 0, buf); + } + } + + for (var i = 1; i < length; i++) { const buf = values[i]; if (!(@ArrayBuffer.@isView(buf) || buf instanceof @ArrayBuffer)) { - @putByValDirect(outValues, i, @Uint8Array(buf.buffer, buf.byteOffset, buf.byteLength)); + @putByValDirect(outValues, i, new @Uint8Array(buf.buffer, buf.byteOffset, buf.byteLength)); + } else { + @putByValDirect(outValues, i, buf); } } + } else { @putByValDirect(outValues, 0, values[0].value); for (var i = 1; i < length; i++) { -- cgit v1.2.3