diff options
| author |  Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
| 2022-06-15 02:00:45 -0700 |
|---|---|---|
| committer | Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
| 2022-06-15 02:00:45 -0700 |
| commit | d93f09331394148441d142930fea236a9fd73c5c (patch) | |
| tree | a1838e49a1ac0d94cfcc13d8a954972cd51677e5 /src/javascript/jsc/bindings/ReadableStreamDefaultReaderBuiltins.cpp | |
| parent | dbde52504d50b8d5bb3e071ce4b5a959c28eb760 (diff) | |
| download | bun-d93f09331394148441d142930fea236a9fd73c5c.tar.gz bun-d93f09331394148441d142930fea236a9fd73c5c.tar.zst bun-d93f09331394148441d142930fea236a9fd73c5c.zip | |
wip direct streams
Diffstat (limited to 'src/javascript/jsc/bindings/ReadableStreamDefaultReaderBuiltins.cpp')
| -rw-r--r-- | src/javascript/jsc/bindings/ReadableStreamDefaultReaderBuiltins.cpp | 28 |
1 files changed, 16 insertions, 12 deletions
diff --git a/src/javascript/jsc/bindings/ReadableStreamDefaultReaderBuiltins.cpp b/src/javascript/jsc/bindings/ReadableStreamDefaultReaderBuiltins.cpp index 91689fb13..b1f8d4791 100644 --- a/src/javascript/jsc/bindings/ReadableStreamDefaultReaderBuiltins.cpp +++ b/src/javascript/jsc/bindings/ReadableStreamDefaultReaderBuiltins.cpp @@ -89,7 +89,7 @@ const char* const s_readableStreamDefaultReaderCancelCode = const JSC::ConstructAbility s_readableStreamDefaultReaderReadManyCodeConstructAbility = JSC::ConstructAbility::CannotConstruct; const JSC::ConstructorKind s_readableStreamDefaultReaderReadManyCodeConstructorKind = JSC::ConstructorKind::None; -const int s_readableStreamDefaultReaderReadManyCodeLength = 3235; +const int s_readableStreamDefaultReaderReadManyCodeLength = 3414; static const JSC::Intrinsic s_readableStreamDefaultReaderReadManyCodeIntrinsic = JSC::NoIntrinsic; const char* const s_readableStreamDefaultReaderReadManyCode = "(function ()\n" \ @@ -118,19 +118,20 @@ const char* const s_readableStreamDefaultReaderReadManyCode = " var size = @getByIdDirectPrivate(controller, \"queue\").size;\n" \ " var values = content.toArray(false);\n" \ " var length = values.length;\n" \ - " \n" \ "\n" \ " if (length > 0) {\n" \ - " for (var i = 0; i < values.length; i++) {\n" \ - " const buf = values[i];\n" \ - " if (!(@ArrayBuffer.@isView(buf) || buf instanceof @ArrayBuffer)) {\n" \ - " values[i] = new @Uint8Array(buf.buffer, buf.byteOffset, buf.byteLength);\n" \ + "\n" \ + " if (@isReadableByteStreamController(controller)) {\n" \ + " for (var i = 0; i < value.length; i++) {\n" \ + " const buf = value[i];\n" \ + " if (!(@ArrayBuffer.@isView(buf) || buf instanceof @ArrayBuffer)) {\n" \ + " value[i] = new @Uint8Array(buf.buffer, buf.byteOffset, buf.byteLength);\n" \ + " }\n" \ " }\n" \ " }\n" \ " \n" \ " @resetQueue(@getByIdDirectPrivate(controller, \"queue\"));\n" \ "\n" \ - " \n" \ " if (@getByIdDirectPrivate(controller, \"closeRequested\"))\n" \ " @readableStreamClose(@getByIdDirectPrivate(controller, \"controlledReadableStream\"));\n" \ " else if (@isReadableStreamDefaultController(controller)) \n" \ @@ -149,13 +150,16 @@ const char* const s_readableStreamDefaultReaderReadManyCode = " \n" \ " var queue = @getByIdDirectPrivate(controller, \"queue\");\n" \ " var value = [result.value].concat(queue.content.toArray(false));\n" \ - " for (var i = 0; i < value.length; i++) {\n" \ - " const buf = value[i];\n" \ - " if (!(@ArrayBuffer.@isView(buf) || buf instanceof @ArrayBuffer)) {\n" \ - " value[i] = new @Uint8Array(buf.buffer, buf.byteOffset, buf.byteLength);\n" \ + "\n" \ + " if (@isReadableByteStreamController(controller)) {\n" \ + " for (var i = 0; i < value.length; i++) {\n" \ + " const buf = value[i];\n" \ + " if (!(@ArrayBuffer.@isView(buf) || buf instanceof @ArrayBuffer)) {\n" \ + " value[i] = new @Uint8Array(buf.buffer, buf.byteOffset, buf.byteLength);\n" \ + " }\n" \ " }\n" \ " }\n" \ - "\n" \ + " \n" \ " var size = queue.size;\n" \ " @resetQueue(queue);\n" \ "\n" \ |