diff options
Diffstat (limited to 'src/bun.js/builtins/cpp/ReadableStreamBuiltins.cpp')
| -rw-r--r-- | src/bun.js/builtins/cpp/ReadableStreamBuiltins.cpp | 98 |
1 files changed, 34 insertions, 64 deletions
diff --git a/src/bun.js/builtins/cpp/ReadableStreamBuiltins.cpp b/src/bun.js/builtins/cpp/ReadableStreamBuiltins.cpp index d60f09e7b..3ce80f2f9 100644 --- a/src/bun.js/builtins/cpp/ReadableStreamBuiltins.cpp +++ b/src/bun.js/builtins/cpp/ReadableStreamBuiltins.cpp @@ -49,7 +49,7 @@ namespace WebCore { const JSC::ConstructAbility s_readableStreamInitializeReadableStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct; const JSC::ConstructorKind s_readableStreamInitializeReadableStreamCodeConstructorKind = JSC::ConstructorKind::None; -const int s_readableStreamInitializeReadableStreamCodeLength = 2783; +const int s_readableStreamInitializeReadableStreamCodeLength = 3256; static const JSC::Intrinsic s_readableStreamInitializeReadableStreamCodeIntrinsic = JSC::NoIntrinsic; const char* const s_readableStreamInitializeReadableStreamCode = "(function (underlyingSource, strategy)\n" \ @@ -74,6 +74,7 @@ const char* const s_readableStreamInitializeReadableStreamCode = " @putByIdDirectPrivate(this, \"storedError\", @undefined);\n" \ " \n" \ " @putByIdDirectPrivate(this, \"disturbed\", false);\n" \ + "\n" \ " \n" \ " //\n" \ " @putByIdDirectPrivate(this, \"readableStreamController\", null);\n" \ @@ -90,6 +91,7 @@ const char* const s_readableStreamInitializeReadableStreamCode = " if (@getByIdDirectPrivate(underlyingSource, \"pull\") !== @undefined && !isLazy) {\n" \ " const size = @getByIdDirectPrivate(strategy, \"size\");\n" \ " const highWaterMark = @getByIdDirectPrivate(strategy, \"highWaterMark\");\n" \ + " @putByIdDirectPrivate(this, \"highWaterMark\", highWaterMark);\n" \ " @putByIdDirectPrivate(this, \"underlyingSource\", @undefined);\n" \ " @setupReadableStreamDefaultController(this, underlyingSource, size, highWaterMark !== @undefined ? highWaterMark : 1, @getByIdDirectPrivate(underlyingSource, \"start\"), @getByIdDirectPrivate(underlyingSource, \"pull\"), @getByIdDirectPrivate(underlyingSource, \"cancel\"));\n" \ " \n" \ @@ -97,10 +99,13 @@ const char* const s_readableStreamInitializeReadableStreamCode = " }\n" \ " if (isDirect) {\n" \ " @putByIdDirectPrivate(this, \"underlyingSource\", underlyingSource);\n" \ + " @putByIdDirectPrivate(this, \"highWaterMark\", @getByIdDirectPrivate(strategy, \"highWaterMark\"));\n" \ " @putByIdDirectPrivate(this, \"start\", () => @createReadableStreamController(this, underlyingSource, strategy));\n" \ " } else if (isLazy) {\n" \ " const autoAllocateChunkSize = underlyingSource.autoAllocateChunkSize;\n" \ + " @putByIdDirectPrivate(this, \"highWaterMark\", @undefined);\n" \ " @putByIdDirectPrivate(this, \"underlyingSource\", @undefined);\n" \ + " @putByIdDirectPrivate(this, \"highWaterMark\", autoAllocateChunkSize || @getByIdDirectPrivate(strategy, \"highWaterMark\"));\n" \ "\n" \ " \n" \ " @putByIdDirectPrivate(this, \"start\", () => {\n" \ @@ -111,6 +116,7 @@ const char* const s_readableStreamInitializeReadableStreamCode = " });\n" \ " } else {\n" \ " @putByIdDirectPrivate(this, \"underlyingSource\", @undefined);\n" \ + " @putByIdDirectPrivate(this, \"highWaterMark\", @getByIdDirectPrivate(strategy, \"highWaterMark\"));\n" \ " @putByIdDirectPrivate(this, \"start\", @undefined);\n" \ " @createReadableStreamController(this, underlyingSource, strategy);\n" \ " }\n" \ @@ -122,48 +128,60 @@ const char* const s_readableStreamInitializeReadableStreamCode = const JSC::ConstructAbility s_readableStreamReadableStreamToArrayCodeConstructAbility = JSC::ConstructAbility::CannotConstruct; const JSC::ConstructorKind s_readableStreamReadableStreamToArrayCodeConstructorKind = JSC::ConstructorKind::None; -const int s_readableStreamReadableStreamToArrayCodeLength = 883; +const int s_readableStreamReadableStreamToArrayCodeLength = 1366; static const JSC::Intrinsic s_readableStreamReadableStreamToArrayCodeIntrinsic = JSC::NoIntrinsic; const char* const s_readableStreamReadableStreamToArrayCode = "(function (stream) {\n" \ " \"use strict\";\n" \ "\n" \ - " if (!stream || @getByIdDirectPrivate(stream, \"state\") === @streamClosed) {\n" \ - " return null;\n" \ + " //\n" \ + " var underlyingSource = @getByIdDirectPrivate(stream, \"underlyingSource\");\n" \ + " if (underlyingSource !== @undefined) { \n" \ + " const promise = @initializeArrayStream.@call(stream, underlyingSource, @undefined);\n" \ + " var reader = stream.getReader();\n" \ + " return (async function() {\n" \ + " while (@getByIdDirectPrivate(stream, \"state\") === @streamReadable) {\n" \ + " var thisResult = await reader.read();\n" \ + " if (thisResult.done) {\n" \ + " break;\n" \ + " }\n" \ + " }\n" \ + "\n" \ + " try {\n" \ + " reader.releaseLock();\n" \ + " } catch(e) {\n" \ + " }\n" \ + "\n" \ + " return await promise;\n" \ + " })();\n" \ " }\n" \ + "\n" \ " var reader = stream.getReader();\n" \ " var manyResult = reader.readMany();\n" \ " \n" \ " async function processManyResult(result) {\n" \ " \n" \ " if (result.done) {\n" \ - " return null;\n" \ + " return [];\n" \ " }\n" \ "\n" \ " var chunks = result.value || [];\n" \ " \n" \ " while (true) {\n" \ " var thisResult = await reader.read();\n" \ - " \n" \ " if (thisResult.done) {\n" \ - " return chunks;\n" \ + " break;\n" \ " }\n" \ - " \n" \ - " chunks.push(thisResult.value);\n" \ + " chunks = chunks.concat(thisResult.value);\n" \ " }\n" \ "\n" \ " return chunks;\n" \ - " };\n" \ - "\n" \ + " }\n" \ "\n" \ " if (manyResult && @isPromise(manyResult)) {\n" \ " return manyResult.@then(processManyResult);\n" \ " }\n" \ "\n" \ - " if (manyResult && manyResult.done) {\n" \ - " return null;\n" \ - " }\n" \ - "\n" \ " return processManyResult(manyResult);\n" \ "})\n" \ ; @@ -213,13 +231,12 @@ const char* const s_readableStreamReadableStreamToTextCode = const JSC::ConstructAbility s_readableStreamReadableStreamToJSONCodeConstructAbility = JSC::ConstructAbility::CannotConstruct; const JSC::ConstructorKind s_readableStreamReadableStreamToJSONCodeConstructorKind = JSC::ConstructorKind::None; -const int s_readableStreamReadableStreamToJSONCodeLength = 121; +const int s_readableStreamReadableStreamToJSONCodeLength = 114; static const JSC::Intrinsic s_readableStreamReadableStreamToJSONCodeIntrinsic = JSC::NoIntrinsic; const char* const s_readableStreamReadableStreamToJSONCode = "(function (stream) {\n" \ " \"use strict\";\n" \ "\n" \ - " //\n" \ " return @readableStreamToText(stream).@then(globalThis.JSON.parse);\n" \ "})\n" \ ; @@ -260,53 +277,6 @@ const char* const s_readableStreamReadableStreamToBlobCode = "})\n" \ ; -const JSC::ConstructAbility s_readableStreamReadableStreamToArrayPublicCodeConstructAbility = JSC::ConstructAbility::CannotConstruct; -const JSC::ConstructorKind s_readableStreamReadableStreamToArrayPublicCodeConstructorKind = JSC::ConstructorKind::None; -const int s_readableStreamReadableStreamToArrayPublicCodeLength = 841; -static const JSC::Intrinsic s_readableStreamReadableStreamToArrayPublicCodeIntrinsic = JSC::NoIntrinsic; -const char* const s_readableStreamReadableStreamToArrayPublicCode = - "(function (stream) {\n" \ - " \"use strict\";\n" \ - "\n" \ - " if (@getByIdDirectPrivate(stream, \"state\") === @streamClosed) {\n" \ - " return [];\n" \ - " }\n" \ - " var reader = stream.getReader();\n" \ - "\n" \ - " var manyResult = reader.readMany();\n" \ - "\n" \ - " var processManyResult = (0, (async function(result) {\n" \ - " if (result.done) {\n" \ - " return [];\n" \ - " }\n" \ - "\n" \ - " var chunks = result.value || [];\n" \ - " \n" \ - " while (true) {\n" \ - " var thisResult = await reader.read();\n" \ - " if (thisResult.done) {\n" \ - " return chunks;\n" \ - " }\n" \ - "\n" \ - " chunks.push(thisResult.value);\n" \ - " }\n" \ - "\n" \ - " return chunks;\n" \ - " }));\n" \ - "\n" \ - "\n" \ - " if (manyResult && @isPromise(manyResult)) {\n" \ - " return manyResult.then(processManyResult);\n" \ - " }\n" \ - "\n" \ - " if (manyResult && manyResult.done) {\n" \ - " return [];\n" \ - " }\n" \ - "\n" \ - " return processManyResult(manyResult);\n" \ - "})\n" \ -; - const JSC::ConstructAbility s_readableStreamConsumeReadableStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct; const JSC::ConstructorKind s_readableStreamConsumeReadableStreamCodeConstructorKind = JSC::ConstructorKind::None; const int s_readableStreamConsumeReadableStreamCodeLength = 3718; |