diff options
| author |  Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
| 2022-06-26 06:01:22 -0700 |
|---|---|---|
| committer | Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
| 2022-06-26 06:01:22 -0700 |
| commit | 77a0f335cb0f18af4e03713583b98e0e1b024b33 (patch) | |
| tree | f6ed90a992cb46677ab597bba4f6db2fbfcba3b1 /src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp | |
| parent | 31cfcf2c9f40520dac72530ec62e765d3a0de221 (diff) | |
| download | bun-77a0f335cb0f18af4e03713583b98e0e1b024b33.tar.gz bun-77a0f335cb0f18af4e03713583b98e0e1b024b33.tar.zst bun-77a0f335cb0f18af4e03713583b98e0e1b024b33.zip | |
wip ReadableStream for HTTP(s) Server
Diffstat (limited to 'src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp')
| -rw-r--r-- | src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp b/src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp index b1f8d4791..9a8935324 100644 --- a/src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp +++ b/src/bun.js/builtins/cpp/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 = 3414; +const int s_readableStreamDefaultReaderReadManyCodeLength = 3712; static const JSC::Intrinsic s_readableStreamDefaultReaderReadManyCodeIntrinsic = JSC::NoIntrinsic; const char* const s_readableStreamDefaultReaderReadManyCode = "(function ()\n" \ @@ -128,6 +128,11 @@ const char* const s_readableStreamDefaultReaderReadManyCode = " value[i] = new @Uint8Array(buf.buffer, buf.byteOffset, buf.byteLength);\n" \ " }\n" \ " }\n" \ + " } else {\n" \ + " values[0] = values[0].value;\n" \ + " for (var i = 1; i < values.length; i++) {\n" \ + " values[i] = values[i].value;\n" \ + " }\n" \ " }\n" \ " \n" \ " @resetQueue(@getByIdDirectPrivate(controller, \"queue\"));\n" \ @@ -158,6 +163,10 @@ const char* const s_readableStreamDefaultReaderReadManyCode = " value[i] = new @Uint8Array(buf.buffer, buf.byteOffset, buf.byteLength);\n" \ " }\n" \ " }\n" \ + " } else {\n" \ + " for (var i = 1; i < value.length; i++) {\n" \ + " value[i] = value[i].value;\n" \ + " }\n" \ " }\n" \ " \n" \ " var size = queue.size;\n" \ |