aboutsummaryrefslogtreecommitdiff
path: root/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp
diff options
context:
space:
mode:
authorGravatar dave caruso <me@paperdave.net> 2023-05-22 18:51:05 -0700
committerGravatar GitHub <noreply@github.com> 2023-05-22 18:51:05 -0700
commitfc40c690ea30a632a8d0d9490321c50ec898d8a5 (patch)
tree6e3ca0bb2c02347006a6b2a09c4aa156b86bd770 /src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp
parent23d42dc2377440dedc9d8e423f1ea077507d62c8 (diff)
downloadbun-fc40c690ea30a632a8d0d9490321c50ec898d8a5.tar.gz
bun-fc40c690ea30a632a8d0d9490321c50ec898d8a5.tar.zst
bun-fc40c690ea30a632a8d0d9490321c50ec898d8a5.zip
Write out builtins with TypeScript + Minify them (#2999)
* start work drafting how builtins will work * work on ts builtin * builtins stuff so far * builtins * done for today * continue work * working on it * bindings so far * well, it builds. doesnt run * IT RUNS * still lots of ts errors but it is functional * sloppy mode
Diffstat (limited to 'src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp')
-rw-r--r--src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp2683
1 files changed, 0 insertions, 2683 deletions
diff --git a/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp b/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp
deleted file mode 100644
index b7d388218..000000000
--- a/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp
+++ /dev/null
@@ -1,2683 +0,0 @@
-/*
- * Copyright (c) 2015 Igalia
- * Copyright (c) 2015 Igalia S.L.
- * Copyright (c) 2015 Igalia.
- * Copyright (c) 2015, 2016 Canon Inc. All rights reserved.
- * Copyright (c) 2015, 2016, 2017 Canon Inc.
- * Copyright (c) 2016, 2020 Apple Inc. All rights reserved.
- * Copyright (c) 2023 Codeblog Corp. All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions
- * are met:
- * 1. Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * 2. Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- *
- * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS''
- * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
- * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
- * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS
- * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
- * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
- * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
- * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
- * THE POSSIBILITY OF SUCH DAMAGE.
- *
- */
-
-// DO NOT EDIT THIS FILE. It is automatically generated from JavaScript files for
-// builtins by the script: Source/JavaScriptCore/Scripts/generate-js-builtins.py
-
-#include "config.h"
-#include "ReadableStreamInternalsBuiltins.h"
-
-#include "WebCoreJSClientData.h"
-#include <JavaScriptCore/IdentifierInlines.h>
-#include <JavaScriptCore/ImplementationVisibility.h>
-#include <JavaScriptCore/Intrinsic.h>
-#include <JavaScriptCore/JSObjectInlines.h>
-#include <JavaScriptCore/VM.h>
-
-namespace WebCore {
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamReaderGenericInitializeCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamReaderGenericInitializeCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamReaderGenericInitializeCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamReaderGenericInitializeCodeLength = 788;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamReaderGenericInitializeCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamReaderGenericInitializeCode =
- "(function (reader, stream) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " @putByIdDirectPrivate(reader, \"ownerReadableStream\", stream);\n" \
- " @putByIdDirectPrivate(stream, \"reader\", reader);\n" \
- " if (@getByIdDirectPrivate(stream, \"state\") === @streamReadable)\n" \
- " @putByIdDirectPrivate(\n" \
- " reader,\n" \
- " \"closedPromiseCapability\",\n" \
- " @newPromiseCapability(@Promise)\n" \
- " );\n" \
- " else if (@getByIdDirectPrivate(stream, \"state\") === @streamClosed)\n" \
- " @putByIdDirectPrivate(reader, \"closedPromiseCapability\", {\n" \
- " @promise: @Promise.@resolve(),\n" \
- " });\n" \
- " else {\n" \
- " @assert(@getByIdDirectPrivate(stream, \"state\") === @streamErrored);\n" \
- " @putByIdDirectPrivate(reader, \"closedPromiseCapability\", {\n" \
- " @promise: @newHandledRejectedPromise(\n" \
- " @getByIdDirectPrivate(stream, \"storedError\")\n" \
- " ),\n" \
- " });\n" \
- " }\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsPrivateInitializeReadableStreamDefaultControllerCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsPrivateInitializeReadableStreamDefaultControllerCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsPrivateInitializeReadableStreamDefaultControllerCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsPrivateInitializeReadableStreamDefaultControllerCodeLength = 873;
-static const JSC::Intrinsic s_readableStreamInternalsPrivateInitializeReadableStreamDefaultControllerCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsPrivateInitializeReadableStreamDefaultControllerCode =
- "(function (\n" \
- " stream,\n" \
- " underlyingSource,\n" \
- " size,\n" \
- " highWaterMark\n" \
- ") {\n" \
- " \"use strict\";\n" \
- "\n" \
- " if (!@isReadableStream(stream))\n" \
- " @throwTypeError(\"ReadableStreamDefaultController needs a ReadableStream\");\n" \
- "\n" \
- " //\n" \
- " if (@getByIdDirectPrivate(stream, \"readableStreamController\") !== null)\n" \
- " @throwTypeError(\"ReadableStream already has a controller\");\n" \
- "\n" \
- " @putByIdDirectPrivate(this, \"controlledReadableStream\", stream);\n" \
- " @putByIdDirectPrivate(this, \"underlyingSource\", underlyingSource);\n" \
- " @putByIdDirectPrivate(this, \"queue\", @newQueue());\n" \
- " @putByIdDirectPrivate(this, \"started\", -1);\n" \
- " @putByIdDirectPrivate(this, \"closeRequested\", false);\n" \
- " @putByIdDirectPrivate(this, \"pullAgain\", false);\n" \
- " @putByIdDirectPrivate(this, \"pulling\", false);\n" \
- " @putByIdDirectPrivate(\n" \
- " this,\n" \
- " \"strategy\",\n" \
- " @validateAndNormalizeQueuingStrategy(size, highWaterMark)\n" \
- " );\n" \
- "\n" \
- " return this;\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamDefaultControllerErrorCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamDefaultControllerErrorCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamDefaultControllerErrorCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamDefaultControllerErrorCodeLength = 305;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamDefaultControllerErrorCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamDefaultControllerErrorCode =
- "(function (controller, error) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " const stream = @getByIdDirectPrivate(controller, \"controlledReadableStream\");\n" \
- " if (@getByIdDirectPrivate(stream, \"state\") !== @streamReadable) return;\n" \
- " @putByIdDirectPrivate(controller, \"queue\", @newQueue());\n" \
- "\n" \
- " @readableStreamError(stream, error);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamPipeToCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamPipeToCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamPipeToCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamPipeToCodeLength = 739;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamPipeToCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamPipeToCode =
- "(function (stream, sink) {\n" \
- " \"use strict\";\n" \
- " @assert(@isReadableStream(stream));\n" \
- "\n" \
- " const reader = new @ReadableStreamDefaultReader(stream);\n" \
- "\n" \
- " @getByIdDirectPrivate(reader, \"closedPromiseCapability\").@promise.@then(\n" \
- " () => {},\n" \
- " (e) => {\n" \
- " sink.error(e);\n" \
- " }\n" \
- " );\n" \
- "\n" \
- " function doPipe() {\n" \
- " @readableStreamDefaultReaderRead(reader).@then(\n" \
- " function (result) {\n" \
- " if (result.done) {\n" \
- " sink.close();\n" \
- " return;\n" \
- " }\n" \
- " try {\n" \
- " sink.enqueue(result.value);\n" \
- " } catch (e) {\n" \
- " sink.error(\"ReadableStream chunk enqueueing in the sink failed\");\n" \
- " return;\n" \
- " }\n" \
- " doPipe();\n" \
- " },\n" \
- " function (e) {\n" \
- " sink.error(e);\n" \
- " }\n" \
- " );\n" \
- " }\n" \
- " doPipe();\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsAcquireReadableStreamDefaultReaderCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsAcquireReadableStreamDefaultReaderCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsAcquireReadableStreamDefaultReaderCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsAcquireReadableStreamDefaultReaderCodeLength = 190;
-static const JSC::Intrinsic s_readableStreamInternalsAcquireReadableStreamDefaultReaderCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsAcquireReadableStreamDefaultReaderCode =
- "(function (stream) {\n" \
- " \"use strict\";\n" \
- " var start = @getByIdDirectPrivate(stream, \"start\");\n" \
- " if (start) {\n" \
- " start.@call(stream);\n" \
- " }\n" \
- "\n" \
- " return new @ReadableStreamDefaultReader(stream);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsSetupReadableStreamDefaultControllerCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsSetupReadableStreamDefaultControllerCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsSetupReadableStreamDefaultControllerCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsSetupReadableStreamDefaultControllerCodeLength = 975;
-static const JSC::Intrinsic s_readableStreamInternalsSetupReadableStreamDefaultControllerCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsSetupReadableStreamDefaultControllerCode =
- "(function (\n" \
- " stream,\n" \
- " underlyingSource,\n" \
- " size,\n" \
- " highWaterMark,\n" \
- " startMethod,\n" \
- " pullMethod,\n" \
- " cancelMethod\n" \
- ") {\n" \
- " \"use strict\";\n" \
- "\n" \
- " const controller = new @ReadableStreamDefaultController(\n" \
- " stream,\n" \
- " underlyingSource,\n" \
- " size,\n" \
- " highWaterMark,\n" \
- " @isReadableStream\n" \
- " );\n" \
- "\n" \
- " const pullAlgorithm = () =>\n" \
- " @promiseInvokeOrNoopMethod(underlyingSource, pullMethod, [controller]);\n" \
- " const cancelAlgorithm = (reason) =>\n" \
- " @promiseInvokeOrNoopMethod(underlyingSource, cancelMethod, [reason]);\n" \
- "\n" \
- " @putByIdDirectPrivate(controller, \"pullAlgorithm\", pullAlgorithm);\n" \
- " @putByIdDirectPrivate(controller, \"cancelAlgorithm\", cancelAlgorithm);\n" \
- " @putByIdDirectPrivate(\n" \
- " controller,\n" \
- " \"pull\",\n" \
- " @readableStreamDefaultControllerPull\n" \
- " );\n" \
- " @putByIdDirectPrivate(\n" \
- " controller,\n" \
- " \"cancel\",\n" \
- " @readableStreamDefaultControllerCancel\n" \
- " );\n" \
- " @putByIdDirectPrivate(stream, \"readableStreamController\", controller);\n" \
- "\n" \
- " @readableStreamDefaultControllerStart(controller);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsCreateReadableStreamControllerCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsCreateReadableStreamControllerCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsCreateReadableStreamControllerCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsCreateReadableStreamControllerCodeLength = 1243;
-static const JSC::Intrinsic s_readableStreamInternalsCreateReadableStreamControllerCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsCreateReadableStreamControllerCode =
- "(function (stream, underlyingSource, strategy) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " const type = underlyingSource.type;\n" \
- " const typeString = @toString(type);\n" \
- "\n" \
- " if (typeString === \"bytes\") {\n" \
- " //\n" \
- " //\n" \
- "\n" \
- " if (strategy.highWaterMark === @undefined) strategy.highWaterMark = 0;\n" \
- " if (strategy.size !== @undefined)\n" \
- " @throwRangeError(\n" \
- " \"Strategy for a ReadableByteStreamController cannot have a size\"\n" \
- " );\n" \
- "\n" \
- " @putByIdDirectPrivate(\n" \
- " stream,\n" \
- " \"readableStreamController\",\n" \
- " new @ReadableByteStreamController(\n" \
- " stream,\n" \
- " underlyingSource,\n" \
- " strategy.highWaterMark,\n" \
- " @isReadableStream\n" \
- " )\n" \
- " );\n" \
- " } else if (typeString === \"direct\") {\n" \
- " var highWaterMark = strategy?.highWaterMark;\n" \
- " @initializeArrayBufferStream.@call(\n" \
- " stream,\n" \
- " underlyingSource,\n" \
- " highWaterMark\n" \
- " );\n" \
- " } else if (type === @undefined) {\n" \
- " if (strategy.highWaterMark === @undefined) strategy.highWaterMark = 1;\n" \
- "\n" \
- " @setupReadableStreamDefaultController(\n" \
- " stream,\n" \
- " underlyingSource,\n" \
- " strategy.size,\n" \
- " strategy.highWaterMark,\n" \
- " underlyingSource.start,\n" \
- " underlyingSource.pull,\n" \
- " underlyingSource.cancel\n" \
- " );\n" \
- " } else @throwRangeError(\"Invalid type for underlying source\");\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamDefaultControllerStartCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamDefaultControllerStartCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamDefaultControllerStartCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamDefaultControllerStartCodeLength = 762;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamDefaultControllerStartCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamDefaultControllerStartCode =
- "(function (controller) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " if (@getByIdDirectPrivate(controller, \"started\") !== -1) return;\n" \
- "\n" \
- " const underlyingSource = @getByIdDirectPrivate(\n" \
- " controller,\n" \
- " \"underlyingSource\"\n" \
- " );\n" \
- " const startMethod = underlyingSource.start;\n" \
- " @putByIdDirectPrivate(controller, \"started\", 0);\n" \
- "\n" \
- " @promiseInvokeOrNoopMethodNoCatch(underlyingSource, startMethod, [\n" \
- " controller,\n" \
- " ]).@then(\n" \
- " () => {\n" \
- " @putByIdDirectPrivate(controller, \"started\", 1);\n" \
- " @assert(!@getByIdDirectPrivate(controller, \"pulling\"));\n" \
- " @assert(!@getByIdDirectPrivate(controller, \"pullAgain\"));\n" \
- " @readableStreamDefaultControllerCallPullIfNeeded(controller);\n" \
- " },\n" \
- " (error) => {\n" \
- " @readableStreamDefaultControllerError(controller, error);\n" \
- " }\n" \
- " );\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamPipeToWritableStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamPipeToWritableStreamCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamPipeToWritableStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamPipeToWritableStreamCodeLength = 3229;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamPipeToWritableStreamCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamPipeToWritableStreamCode =
- "(function (\n" \
- " source,\n" \
- " destination,\n" \
- " preventClose,\n" \
- " preventAbort,\n" \
- " preventCancel,\n" \
- " signal\n" \
- ") {\n" \
- " \"use strict\";\n" \
- "\n" \
- " const isDirectStream = !!@getByIdDirectPrivate(source, \"start\");\n" \
- "\n" \
- "\n" \
- " @assert(@isReadableStream(source));\n" \
- " @assert(@isWritableStream(destination));\n" \
- " @assert(!@isReadableStreamLocked(source));\n" \
- " @assert(!@isWritableStreamLocked(destination));\n" \
- " @assert(signal === @undefined || @isAbortSignal(signal));\n" \
- "\n" \
- " if (@getByIdDirectPrivate(source, \"underlyingByteSource\") !== @undefined)\n" \
- " return @Promise.@reject(\n" \
- " \"Piping to a readable bytestream is not supported\"\n" \
- " );\n" \
- "\n" \
- " let pipeState = {\n" \
- " source: source,\n" \
- " destination: destination,\n" \
- " preventAbort: preventAbort,\n" \
- " preventCancel: preventCancel,\n" \
- " preventClose: preventClose,\n" \
- " signal: signal,\n" \
- " };\n" \
- "\n" \
- " pipeState.reader = @acquireReadableStreamDefaultReader(source);\n" \
- " pipeState.writer = @acquireWritableStreamDefaultWriter(destination);\n" \
- "\n" \
- " @putByIdDirectPrivate(source, \"disturbed\", true);\n" \
- "\n" \
- " pipeState.finalized = false;\n" \
- " pipeState.shuttingDown = false;\n" \
- " pipeState.promiseCapability = @newPromiseCapability(@Promise);\n" \
- " pipeState.pendingReadPromiseCapability = @newPromiseCapability(@Promise);\n" \
- " pipeState.pendingReadPromiseCapability.@resolve.@call();\n" \
- " pipeState.pendingWritePromise = @Promise.@resolve();\n" \
- "\n" \
- " if (signal !== @undefined) {\n" \
- " const algorithm = (reason) => {\n" \
- " if (pipeState.finalized) return;\n" \
- "\n" \
- " @pipeToShutdownWithAction(\n" \
- " pipeState,\n" \
- " () => {\n" \
- " const shouldAbortDestination =\n" \
- " !pipeState.preventAbort &&\n" \
- " @getByIdDirectPrivate(pipeState.destination, \"state\") ===\n" \
- " \"writable\";\n" \
- " const promiseDestination = shouldAbortDestination\n" \
- " ? @writableStreamAbort(pipeState.destination, reason)\n" \
- " : @Promise.@resolve();\n" \
- "\n" \
- " const shouldAbortSource =\n" \
- " !pipeState.preventCancel &&\n" \
- " @getByIdDirectPrivate(pipeState.source, \"state\") ===\n" \
- " @streamReadable;\n" \
- " const promiseSource = shouldAbortSource\n" \
- " ? @readableStreamCancel(pipeState.source, reason)\n" \
- " : @Promise.@resolve();\n" \
- "\n" \
- " let promiseCapability = @newPromiseCapability(@Promise);\n" \
- " let shouldWait = true;\n" \
- " let handleResolvedPromise = () => {\n" \
- " if (shouldWait) {\n" \
- " shouldWait = false;\n" \
- " return;\n" \
- " }\n" \
- " promiseCapability.@resolve.@call();\n" \
- " };\n" \
- " let handleRejectedPromise = (e) => {\n" \
- " promiseCapability.@reject.@call(@undefined, e);\n" \
- " };\n" \
- " promiseDestination.@then(\n" \
- " handleResolvedPromise,\n" \
- " handleRejectedPromise\n" \
- " );\n" \
- " promiseSource.@then(handleResolvedPromise, handleRejectedPromise);\n" \
- " return promiseCapability.@promise;\n" \
- " },\n" \
- " reason\n" \
- " );\n" \
- " };\n" \
- " if (@whenSignalAborted(signal, algorithm))\n" \
- " return pipeState.promiseCapability.@promise;\n" \
- " }\n" \
- "\n" \
- " @pipeToErrorsMustBePropagatedForward(pipeState);\n" \
- " @pipeToErrorsMustBePropagatedBackward(pipeState);\n" \
- " @pipeToClosingMustBePropagatedForward(pipeState);\n" \
- " @pipeToClosingMustBePropagatedBackward(pipeState);\n" \
- "\n" \
- " @pipeToLoop(pipeState);\n" \
- "\n" \
- " return pipeState.promiseCapability.@promise;\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsPipeToLoopCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsPipeToLoopCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsPipeToLoopCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsPipeToLoopCodeLength = 180;
-static const JSC::Intrinsic s_readableStreamInternalsPipeToLoopCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsPipeToLoopCode =
- "(function (pipeState) {\n" \
- " \"use strict\";\n" \
- " if (pipeState.shuttingDown) return;\n" \
- "\n" \
- " @pipeToDoReadWrite(pipeState).@then((result) => {\n" \
- " if (result) @pipeToLoop(pipeState);\n" \
- " });\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsPipeToDoReadWriteCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsPipeToDoReadWriteCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsPipeToDoReadWriteCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsPipeToDoReadWriteCodeLength = 1296;
-static const JSC::Intrinsic s_readableStreamInternalsPipeToDoReadWriteCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsPipeToDoReadWriteCode =
- "(function (pipeState) {\n" \
- " \"use strict\";\n" \
- " @assert(!pipeState.shuttingDown);\n" \
- "\n" \
- " pipeState.pendingReadPromiseCapability = @newPromiseCapability(@Promise);\n" \
- " @getByIdDirectPrivate(pipeState.writer, \"readyPromise\").@promise.@then(\n" \
- " () => {\n" \
- " if (pipeState.shuttingDown) {\n" \
- " pipeState.pendingReadPromiseCapability.@resolve.@call(\n" \
- " @undefined,\n" \
- " false\n" \
- " );\n" \
- " return;\n" \
- " }\n" \
- "\n" \
- " @readableStreamDefaultReaderRead(pipeState.reader).@then(\n" \
- " (result) => {\n" \
- " const canWrite =\n" \
- " !result.done &&\n" \
- " @getByIdDirectPrivate(pipeState.writer, \"stream\") !== @undefined;\n" \
- " pipeState.pendingReadPromiseCapability.@resolve.@call(\n" \
- " @undefined,\n" \
- " canWrite\n" \
- " );\n" \
- " if (!canWrite) return;\n" \
- "\n" \
- " pipeState.pendingWritePromise = @writableStreamDefaultWriterWrite(\n" \
- " pipeState.writer,\n" \
- " result.value\n" \
- " );\n" \
- " },\n" \
- " (e) => {\n" \
- " pipeState.pendingReadPromiseCapability.@resolve.@call(\n" \
- " @undefined,\n" \
- " false\n" \
- " );\n" \
- " }\n" \
- " );\n" \
- " },\n" \
- " (e) => {\n" \
- " pipeState.pendingReadPromiseCapability.@resolve.@call(\n" \
- " @undefined,\n" \
- " false\n" \
- " );\n" \
- " }\n" \
- " );\n" \
- " return pipeState.pendingReadPromiseCapability.@promise;\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsPipeToErrorsMustBePropagatedForwardCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsPipeToErrorsMustBePropagatedForwardCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsPipeToErrorsMustBePropagatedForwardCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsPipeToErrorsMustBePropagatedForwardCodeLength = 687;
-static const JSC::Intrinsic s_readableStreamInternalsPipeToErrorsMustBePropagatedForwardCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsPipeToErrorsMustBePropagatedForwardCode =
- "(function (pipeState) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " const action = () => {\n" \
- " pipeState.pendingReadPromiseCapability.@resolve.@call(@undefined, false);\n" \
- " const error = @getByIdDirectPrivate(pipeState.source, \"storedError\");\n" \
- " if (!pipeState.preventAbort) {\n" \
- " @pipeToShutdownWithAction(\n" \
- " pipeState,\n" \
- " () => @writableStreamAbort(pipeState.destination, error),\n" \
- " error\n" \
- " );\n" \
- " return;\n" \
- " }\n" \
- " @pipeToShutdown(pipeState, error);\n" \
- " };\n" \
- "\n" \
- " if (@getByIdDirectPrivate(pipeState.source, \"state\") === @streamErrored) {\n" \
- " action();\n" \
- " return;\n" \
- " }\n" \
- "\n" \
- " @getByIdDirectPrivate(\n" \
- " pipeState.reader,\n" \
- " \"closedPromiseCapability\"\n" \
- " ).@promise.@then(@undefined, action);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsPipeToErrorsMustBePropagatedBackwardCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsPipeToErrorsMustBePropagatedBackwardCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsPipeToErrorsMustBePropagatedBackwardCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsPipeToErrorsMustBePropagatedBackwardCodeLength = 598;
-static const JSC::Intrinsic s_readableStreamInternalsPipeToErrorsMustBePropagatedBackwardCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsPipeToErrorsMustBePropagatedBackwardCode =
- "(function (pipeState) {\n" \
- " \"use strict\";\n" \
- " const action = () => {\n" \
- " const error = @getByIdDirectPrivate(pipeState.destination, \"storedError\");\n" \
- " if (!pipeState.preventCancel) {\n" \
- " @pipeToShutdownWithAction(\n" \
- " pipeState,\n" \
- " () => @readableStreamCancel(pipeState.source, error),\n" \
- " error\n" \
- " );\n" \
- " return;\n" \
- " }\n" \
- " @pipeToShutdown(pipeState, error);\n" \
- " };\n" \
- " if (@getByIdDirectPrivate(pipeState.destination, \"state\") === \"errored\") {\n" \
- " action();\n" \
- " return;\n" \
- " }\n" \
- " @getByIdDirectPrivate(pipeState.writer, \"closedPromise\").@promise.@then(\n" \
- " @undefined,\n" \
- " action\n" \
- " );\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsPipeToClosingMustBePropagatedForwardCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsPipeToClosingMustBePropagatedForwardCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsPipeToClosingMustBePropagatedForwardCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsPipeToClosingMustBePropagatedForwardCodeLength = 673;
-static const JSC::Intrinsic s_readableStreamInternalsPipeToClosingMustBePropagatedForwardCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsPipeToClosingMustBePropagatedForwardCode =
- "(function (pipeState) {\n" \
- " \"use strict\";\n" \
- " const action = () => {\n" \
- " pipeState.pendingReadPromiseCapability.@resolve.@call(@undefined, false);\n" \
- " const error = @getByIdDirectPrivate(pipeState.source, \"storedError\");\n" \
- " if (!pipeState.preventClose) {\n" \
- " @pipeToShutdownWithAction(pipeState, () =>\n" \
- " @writableStreamDefaultWriterCloseWithErrorPropagation(pipeState.writer)\n" \
- " );\n" \
- " return;\n" \
- " }\n" \
- " @pipeToShutdown(pipeState);\n" \
- " };\n" \
- " if (@getByIdDirectPrivate(pipeState.source, \"state\") === @streamClosed) {\n" \
- " action();\n" \
- " return;\n" \
- " }\n" \
- " @getByIdDirectPrivate(\n" \
- " pipeState.reader,\n" \
- " \"closedPromiseCapability\"\n" \
- " ).@promise.@then(action, @undefined);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsPipeToClosingMustBePropagatedBackwardCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsPipeToClosingMustBePropagatedBackwardCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsPipeToClosingMustBePropagatedBackwardCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsPipeToClosingMustBePropagatedBackwardCodeLength = 492;
-static const JSC::Intrinsic s_readableStreamInternalsPipeToClosingMustBePropagatedBackwardCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsPipeToClosingMustBePropagatedBackwardCode =
- "(function (pipeState) {\n" \
- " \"use strict\";\n" \
- " if (\n" \
- " !@writableStreamCloseQueuedOrInFlight(pipeState.destination) &&\n" \
- " @getByIdDirectPrivate(pipeState.destination, \"state\") !== \"closed\"\n" \
- " )\n" \
- " return;\n" \
- "\n" \
- " //\n" \
- "\n" \
- " const error = @makeTypeError(\"closing is propagated backward\");\n" \
- " if (!pipeState.preventCancel) {\n" \
- " @pipeToShutdownWithAction(\n" \
- " pipeState,\n" \
- " () => @readableStreamCancel(pipeState.source, error),\n" \
- " error\n" \
- " );\n" \
- " return;\n" \
- " }\n" \
- " @pipeToShutdown(pipeState, error);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsPipeToShutdownWithActionCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsPipeToShutdownWithActionCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsPipeToShutdownWithActionCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsPipeToShutdownWithActionCodeLength = 850;
-static const JSC::Intrinsic s_readableStreamInternalsPipeToShutdownWithActionCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsPipeToShutdownWithActionCode =
- "(function (pipeState, action) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " if (pipeState.shuttingDown) return;\n" \
- "\n" \
- " pipeState.shuttingDown = true;\n" \
- "\n" \
- " const hasError = arguments.length > 2;\n" \
- " const error = arguments[2];\n" \
- " const finalize = () => {\n" \
- " const promise = action();\n" \
- " promise.@then(\n" \
- " () => {\n" \
- " if (hasError) @pipeToFinalize(pipeState, error);\n" \
- " else @pipeToFinalize(pipeState);\n" \
- " },\n" \
- " (e) => {\n" \
- " @pipeToFinalize(pipeState, e);\n" \
- " }\n" \
- " );\n" \
- " };\n" \
- "\n" \
- " if (\n" \
- " @getByIdDirectPrivate(pipeState.destination, \"state\") === \"writable\" &&\n" \
- " !@writableStreamCloseQueuedOrInFlight(pipeState.destination)\n" \
- " ) {\n" \
- " pipeState.pendingReadPromiseCapability.@promise.@then(\n" \
- " () => {\n" \
- " pipeState.pendingWritePromise.@then(finalize, finalize);\n" \
- " },\n" \
- " (e) => @pipeToFinalize(pipeState, e)\n" \
- " );\n" \
- " return;\n" \
- " }\n" \
- "\n" \
- " finalize();\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsPipeToShutdownCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsPipeToShutdownCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsPipeToShutdownCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsPipeToShutdownCodeLength = 692;
-static const JSC::Intrinsic s_readableStreamInternalsPipeToShutdownCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsPipeToShutdownCode =
- "(function (pipeState) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " if (pipeState.shuttingDown) return;\n" \
- "\n" \
- " pipeState.shuttingDown = true;\n" \
- "\n" \
- " const hasError = arguments.length > 1;\n" \
- " const error = arguments[1];\n" \
- " const finalize = () => {\n" \
- " if (hasError) @pipeToFinalize(pipeState, error);\n" \
- " else @pipeToFinalize(pipeState);\n" \
- " };\n" \
- "\n" \
- " if (\n" \
- " @getByIdDirectPrivate(pipeState.destination, \"state\") === \"writable\" &&\n" \
- " !@writableStreamCloseQueuedOrInFlight(pipeState.destination)\n" \
- " ) {\n" \
- " pipeState.pendingReadPromiseCapability.@promise.@then(\n" \
- " () => {\n" \
- " pipeState.pendingWritePromise.@then(finalize, finalize);\n" \
- " },\n" \
- " (e) => @pipeToFinalize(pipeState, e)\n" \
- " );\n" \
- " return;\n" \
- " }\n" \
- " finalize();\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsPipeToFinalizeCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsPipeToFinalizeCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsPipeToFinalizeCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsPipeToFinalizeCodeLength = 349;
-static const JSC::Intrinsic s_readableStreamInternalsPipeToFinalizeCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsPipeToFinalizeCode =
- "(function (pipeState) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " @writableStreamDefaultWriterRelease(pipeState.writer);\n" \
- " @readableStreamReaderGenericRelease(pipeState.reader);\n" \
- "\n" \
- " //\n" \
- " pipeState.finalized = true;\n" \
- "\n" \
- " if (arguments.length > 1)\n" \
- " pipeState.promiseCapability.@reject.@call(@undefined, arguments[1]);\n" \
- " else pipeState.promiseCapability.@resolve.@call();\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamTeeCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamTeeCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamTeeCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamTeeCodeLength = 1839;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamTeeCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamTeeCode =
- "(function (stream, shouldClone) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " @assert(@isReadableStream(stream));\n" \
- " @assert(typeof shouldClone === \"boolean\");\n" \
- "\n" \
- " var start_ = @getByIdDirectPrivate(stream, \"start\");\n" \
- " if (start_) {\n" \
- " @putByIdDirectPrivate(stream, \"start\", @undefined);\n" \
- " start_();\n" \
- " }\n" \
- "\n" \
- " const reader = new @ReadableStreamDefaultReader(stream);\n" \
- "\n" \
- " const teeState = {\n" \
- " closedOrErrored: false,\n" \
- " canceled1: false,\n" \
- " canceled2: false,\n" \
- " reason1: @undefined,\n" \
- " reason2: @undefined,\n" \
- " };\n" \
- "\n" \
- " teeState.cancelPromiseCapability = @newPromiseCapability(@Promise);\n" \
- "\n" \
- " const pullFunction = @readableStreamTeePullFunction(\n" \
- " teeState,\n" \
- " reader,\n" \
- " shouldClone\n" \
- " );\n" \
- "\n" \
- " const branch1Source = {};\n" \
- " @putByIdDirectPrivate(branch1Source, \"pull\", pullFunction);\n" \
- " @putByIdDirectPrivate(\n" \
- " branch1Source,\n" \
- " \"cancel\",\n" \
- " @readableStreamTeeBranch1CancelFunction(teeState, stream)\n" \
- " );\n" \
- "\n" \
- " const branch2Source = {};\n" \
- " @putByIdDirectPrivate(branch2Source, \"pull\", pullFunction);\n" \
- " @putByIdDirectPrivate(\n" \
- " branch2Source,\n" \
- " \"cancel\",\n" \
- " @readableStreamTeeBranch2CancelFunction(teeState, stream)\n" \
- " );\n" \
- "\n" \
- " const branch1 = new @ReadableStream(branch1Source);\n" \
- " const branch2 = new @ReadableStream(branch2Source);\n" \
- "\n" \
- " @getByIdDirectPrivate(reader, \"closedPromiseCapability\").@promise.@then(\n" \
- " @undefined,\n" \
- " function (e) {\n" \
- " if (teeState.closedOrErrored) return;\n" \
- " @readableStreamDefaultControllerError(\n" \
- " branch1.@readableStreamController,\n" \
- " e\n" \
- " );\n" \
- " @readableStreamDefaultControllerError(\n" \
- " branch2.@readableStreamController,\n" \
- " e\n" \
- " );\n" \
- " teeState.closedOrErrored = true;\n" \
- " if (!teeState.canceled1 || !teeState.canceled2)\n" \
- " teeState.cancelPromiseCapability.@resolve.@call();\n" \
- " }\n" \
- " );\n" \
- "\n" \
- " //\n" \
- " teeState.branch1 = branch1;\n" \
- " teeState.branch2 = branch2;\n" \
- "\n" \
- " return [branch1, branch2];\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamTeePullFunctionCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamTeePullFunctionCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamTeePullFunctionCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamTeePullFunctionCodeLength = 1336;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamTeePullFunctionCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamTeePullFunctionCode =
- "(function (teeState, reader, shouldClone) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " return function () {\n" \
- " @Promise.prototype.@then.@call(\n" \
- " @readableStreamDefaultReaderRead(reader),\n" \
- " function (result) {\n" \
- " @assert(@isObject(result));\n" \
- " @assert(typeof result.done === \"boolean\");\n" \
- " if (result.done && !teeState.closedOrErrored) {\n" \
- " if (!teeState.canceled1)\n" \
- " @readableStreamDefaultControllerClose(\n" \
- " teeState.branch1.@readableStreamController\n" \
- " );\n" \
- " if (!teeState.canceled2)\n" \
- " @readableStreamDefaultControllerClose(\n" \
- " teeState.branch2.@readableStreamController\n" \
- " );\n" \
- " teeState.closedOrErrored = true;\n" \
- " if (!teeState.canceled1 || !teeState.canceled2)\n" \
- " teeState.cancelPromiseCapability.@resolve.@call();\n" \
- " }\n" \
- " if (teeState.closedOrErrored) return;\n" \
- " if (!teeState.canceled1)\n" \
- " @readableStreamDefaultControllerEnqueue(\n" \
- " teeState.branch1.@readableStreamController,\n" \
- " result.value\n" \
- " );\n" \
- " if (!teeState.canceled2)\n" \
- " @readableStreamDefaultControllerEnqueue(\n" \
- " teeState.branch2.@readableStreamController,\n" \
- " shouldClone\n" \
- " ? @structuredCloneForStream(result.value)\n" \
- " : result.value\n" \
- " );\n" \
- " }\n" \
- " );\n" \
- " };\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamTeeBranch1CancelFunctionCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamTeeBranch1CancelFunctionCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamTeeBranch1CancelFunctionCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamTeeBranch1CancelFunctionCodeLength = 442;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamTeeBranch1CancelFunctionCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamTeeBranch1CancelFunctionCode =
- "(function (teeState, stream) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " return function (r) {\n" \
- " teeState.canceled1 = true;\n" \
- " teeState.reason1 = r;\n" \
- " if (teeState.canceled2) {\n" \
- " @readableStreamCancel(stream, [\n" \
- " teeState.reason1,\n" \
- " teeState.reason2,\n" \
- " ]).@then(\n" \
- " teeState.cancelPromiseCapability.@resolve,\n" \
- " teeState.cancelPromiseCapability.@reject\n" \
- " );\n" \
- " }\n" \
- " return teeState.cancelPromiseCapability.@promise;\n" \
- " };\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamTeeBranch2CancelFunctionCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamTeeBranch2CancelFunctionCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamTeeBranch2CancelFunctionCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamTeeBranch2CancelFunctionCodeLength = 442;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamTeeBranch2CancelFunctionCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamTeeBranch2CancelFunctionCode =
- "(function (teeState, stream) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " return function (r) {\n" \
- " teeState.canceled2 = true;\n" \
- " teeState.reason2 = r;\n" \
- " if (teeState.canceled1) {\n" \
- " @readableStreamCancel(stream, [\n" \
- " teeState.reason1,\n" \
- " teeState.reason2,\n" \
- " ]).@then(\n" \
- " teeState.cancelPromiseCapability.@resolve,\n" \
- " teeState.cancelPromiseCapability.@reject\n" \
- " );\n" \
- " }\n" \
- " return teeState.cancelPromiseCapability.@promise;\n" \
- " };\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsIsReadableStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsIsReadableStreamCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsIsReadableStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsIsReadableStreamCodeLength = 174;
-static const JSC::Intrinsic s_readableStreamInternalsIsReadableStreamCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsIsReadableStreamCode =
- "(function (stream) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " //\n" \
- " //\n" \
- " //\n" \
- " return (\n" \
- " @isObject(stream) &&\n" \
- " @getByIdDirectPrivate(stream, \"readableStreamController\") !== @undefined\n" \
- " );\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsIsReadableStreamDefaultReaderCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsIsReadableStreamDefaultReaderCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsIsReadableStreamDefaultReaderCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsIsReadableStreamDefaultReaderCodeLength = 135;
-static const JSC::Intrinsic s_readableStreamInternalsIsReadableStreamDefaultReaderCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsIsReadableStreamDefaultReaderCode =
- "(function (reader) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " //\n" \
- " //\n" \
- " //\n" \
- " return @isObject(reader) && !!@getByIdDirectPrivate(reader, \"readRequests\");\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsIsReadableStreamDefaultControllerCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsIsReadableStreamDefaultControllerCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsIsReadableStreamDefaultControllerCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsIsReadableStreamDefaultControllerCodeLength = 170;
-static const JSC::Intrinsic s_readableStreamInternalsIsReadableStreamDefaultControllerCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsIsReadableStreamDefaultControllerCode =
- "(function (controller) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " //\n" \
- " //\n" \
- " //\n" \
- " //\n" \
- " return (\n" \
- " @isObject(controller) &&\n" \
- " !!@getByIdDirectPrivate(controller, \"underlyingSource\")\n" \
- " );\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadDirectStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadDirectStreamCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadDirectStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadDirectStreamCodeLength = 1583;
-static const JSC::Intrinsic s_readableStreamInternalsReadDirectStreamCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadDirectStreamCode =
- "(function (stream, sink, underlyingSource) {\n" \
- " \"use strict\";\n" \
- " \n" \
- " @putByIdDirectPrivate(stream, \"underlyingSource\", @undefined);\n" \
- " @putByIdDirectPrivate(stream, \"start\", @undefined);\n" \
- "\n" \
- " function close(stream, reason) {\n" \
- " if (reason && underlyingSource?.cancel) {\n" \
- " try {\n" \
- " var prom = underlyingSource.cancel(reason);\n" \
- " @markPromiseAsHandled(prom);\n" \
- " } catch (e) {\n" \
- " }\n" \
- "\n" \
- " underlyingSource = @undefined;\n" \
- " }\n" \
- "\n" \
- " if (stream) {\n" \
- " @putByIdDirectPrivate(stream, \"readableStreamController\", @undefined);\n" \
- " @putByIdDirectPrivate(stream, \"reader\", @undefined);\n" \
- " if (reason) {\n" \
- " @putByIdDirectPrivate(stream, \"state\", @streamErrored);\n" \
- " @putByIdDirectPrivate(stream, \"storedError\", reason);\n" \
- " } else {\n" \
- " @putByIdDirectPrivate(stream, \"state\", @streamClosed);\n" \
- " }\n" \
- " stream = @undefined;\n" \
- " }\n" \
- " }\n" \
- "\n" \
- "\n" \
- "\n" \
- "\n" \
- "\n" \
- " if (!underlyingSource.pull) {\n" \
- " close();\n" \
- " return;\n" \
- " }\n" \
- "\n" \
- " if (!@isCallable(underlyingSource.pull)) {\n" \
- " close();\n" \
- " @throwTypeError(\"pull is not a function\");\n" \
- " return;\n" \
- " }\n" \
- "\n" \
- " @putByIdDirectPrivate(stream, \"readableStreamController\", sink);\n" \
- " const highWaterMark = @getByIdDirectPrivate(stream, \"highWaterMark\");\n" \
- "\n" \
- " sink.start({\n" \
- " highWaterMark: !highWaterMark || highWaterMark < 64 ? 64 : highWaterMark,\n" \
- " });\n" \
- "\n" \
- " @startDirectStream.@call(sink, stream, underlyingSource.pull, close);\n" \
- " @putByIdDirectPrivate(stream, \"reader\", {});\n" \
- "\n" \
- " var maybePromise = underlyingSource.pull(sink);\n" \
- " sink = @undefined;\n" \
- " if (maybePromise && @isPromise(maybePromise)) {\n" \
- " return maybePromise.@then(() => {});\n" \
- " }\n" \
- "\n" \
- "\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsAssignToStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsAssignToStreamCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsAssignToStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsAssignToStreamCodeLength = 438;
-static const JSC::Intrinsic s_readableStreamInternalsAssignToStreamCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsAssignToStreamCode =
- "(function (stream, sink) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " //\n" \
- " var underlyingSource = @getByIdDirectPrivate(stream, \"underlyingSource\");\n" \
- "\n" \
- " //\n" \
- " if (underlyingSource) {\n" \
- " try {\n" \
- " return @readDirectStream(stream, sink, underlyingSource);\n" \
- " } catch(e) {\n" \
- " throw e;\n" \
- " } finally {\n" \
- " underlyingSource = @undefined;\n" \
- " stream = @undefined;\n" \
- " sink = @undefined;\n" \
- " }\n" \
- " \n" \
- "\n" \
- " }\n" \
- "\n" \
- " return @readStreamIntoSink(stream, sink, true);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadStreamIntoSinkCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadStreamIntoSinkCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadStreamIntoSinkCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadStreamIntoSinkCodeLength = 2869;
-static const JSC::Intrinsic s_readableStreamInternalsReadStreamIntoSinkCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadStreamIntoSinkCode =
- "(async function (stream, sink, isNative) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " var didClose = false;\n" \
- " var didThrow = false;\n" \
- " try {\n" \
- " var reader = stream.getReader();\n" \
- " var many = reader.readMany();\n" \
- " if (many && @isPromise(many)) {\n" \
- " many = await many;\n" \
- " }\n" \
- " if (many.done) {\n" \
- " didClose = true;\n" \
- " return sink.end();\n" \
- " }\n" \
- " var wroteCount = many.value.length;\n" \
- " const highWaterMark = @getByIdDirectPrivate(stream, \"highWaterMark\");\n" \
- " if (isNative) @startDirectStream.@call(sink, stream, @undefined, () => !didThrow && @markPromiseAsHandled(stream.cancel()));\n" \
- "\n" \
- " sink.start({ highWaterMark: highWaterMark || 0 });\n" \
- " \n" \
- "\n" \
- " for (\n" \
- " var i = 0, values = many.value, length = many.value.length;\n" \
- " i < length;\n" \
- " i++\n" \
- " ) {\n" \
- " sink.write(values[i]);\n" \
- " }\n" \
- "\n" \
- " var streamState = @getByIdDirectPrivate(stream, \"state\");\n" \
- " if (streamState === @streamClosed) {\n" \
- " didClose = true;\n" \
- " return sink.end();\n" \
- " }\n" \
- "\n" \
- " while (true) {\n" \
- " var { value, done } = await reader.read();\n" \
- " if (done) {\n" \
- " didClose = true;\n" \
- " return sink.end();\n" \
- " }\n" \
- "\n" \
- " sink.write(value);\n" \
- " }\n" \
- " } catch (e) {\n" \
- " didThrow = true;\n" \
- "\n" \
- "\n" \
- " try {\n" \
- " reader = @undefined;\n" \
- " const prom = stream.cancel(e);\n" \
- " @markPromiseAsHandled(prom);\n" \
- " } catch (j) {}\n" \
- "\n" \
- " if (sink && !didClose) {\n" \
- " didClose = true;\n" \
- " try {\n" \
- " sink.close(e);\n" \
- " } catch (j) {\n" \
- " throw new globalThis.AggregateError([e, j]);\n" \
- " }\n" \
- " }\n" \
- "\n" \
- "\n" \
- " throw e;\n" \
- " } finally {\n" \
- " if (reader) {\n" \
- " try {\n" \
- " reader.releaseLock();\n" \
- " } catch (e) {}\n" \
- " reader = @undefined;\n" \
- " }\n" \
- " sink = @undefined;\n" \
- " var streamState = @getByIdDirectPrivate(stream, \"state\");\n" \
- " if (stream) {\n" \
- "\n" \
- " //\n" \
- " //\n" \
- " var readableStreamController = @getByIdDirectPrivate(\n" \
- " stream,\n" \
- " \"readableStreamController\"\n" \
- " );\n" \
- " if (readableStreamController) {\n" \
- " if (\n" \
- " @getByIdDirectPrivate(readableStreamController, \"underlyingSource\")\n" \
- " )\n" \
- " @putByIdDirectPrivate(\n" \
- " readableStreamController,\n" \
- " \"underlyingSource\",\n" \
- " @undefined\n" \
- " );\n" \
- " if (\n" \
- " @getByIdDirectPrivate(\n" \
- " readableStreamController,\n" \
- " \"controlledReadableStream\"\n" \
- " )\n" \
- " )\n" \
- " @putByIdDirectPrivate(\n" \
- " readableStreamController,\n" \
- " \"controlledReadableStream\",\n" \
- " @undefined\n" \
- " );\n" \
- "\n" \
- " @putByIdDirectPrivate(stream, \"readableStreamController\", null);\n" \
- " if (@getByIdDirectPrivate(stream, \"underlyingSource\"))\n" \
- " @putByIdDirectPrivate(stream, \"underlyingSource\", @undefined);\n" \
- " readableStreamController = @undefined;\n" \
- " }\n" \
- "\n" \
- " if (!didThrow && streamState !== @streamClosed && streamState !== @streamErrored) {\n" \
- " @readableStreamClose(stream);\n" \
- " }\n" \
- " stream = @undefined;\n" \
- "\n" \
- " \n" \
- " }\n" \
- " }\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsHandleDirectStreamErrorCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsHandleDirectStreamErrorCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsHandleDirectStreamErrorCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsHandleDirectStreamErrorCodeLength = 774;
-static const JSC::Intrinsic s_readableStreamInternalsHandleDirectStreamErrorCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsHandleDirectStreamErrorCode =
- "(function (e) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " var controller = this;\n" \
- " var sink = controller.@sink;\n" \
- " if (sink) {\n" \
- " @putByIdDirectPrivate(controller, \"sink\", @undefined);\n" \
- " try {\n" \
- " sink.close(e);\n" \
- " } catch (f) {}\n" \
- " }\n" \
- "\n" \
- " this.error =\n" \
- " this.flush =\n" \
- " this.write =\n" \
- " this.close =\n" \
- " this.end =\n" \
- " @onReadableStreamDirectControllerClosed;\n" \
- "\n" \
- " if (typeof this.@underlyingSource.close === \"function\") {\n" \
- " try {\n" \
- " this.@underlyingSource.close.@call(this.@underlyingSource, e);\n" \
- " } catch (e) {}\n" \
- " }\n" \
- "\n" \
- " try {\n" \
- " var pend = controller._pendingRead;\n" \
- " if (pend) {\n" \
- " controller._pendingRead = @undefined;\n" \
- " @rejectPromise(pend, e);\n" \
- " }\n" \
- " } catch (f) {}\n" \
- " var stream = controller.@controlledReadableStream;\n" \
- " if (stream) @readableStreamError(stream, e);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsHandleDirectStreamErrorRejectCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsHandleDirectStreamErrorRejectCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsHandleDirectStreamErrorRejectCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsHandleDirectStreamErrorRejectCodeLength = 92;
-static const JSC::Intrinsic s_readableStreamInternalsHandleDirectStreamErrorRejectCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsHandleDirectStreamErrorRejectCode =
- "(function (e) {\n" \
- " @handleDirectStreamError.@call(this, e);\n" \
- " return @Promise.@reject(e);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsOnPullDirectStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsOnPullDirectStreamCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsOnPullDirectStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsOnPullDirectStreamCodeLength = 1503;
-static const JSC::Intrinsic s_readableStreamInternalsOnPullDirectStreamCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsOnPullDirectStreamCode =
- "(function (controller) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " var stream = controller.@controlledReadableStream;\n" \
- " if (!stream || @getByIdDirectPrivate(stream, \"state\") !== @streamReadable)\n" \
- " return;\n" \
- "\n" \
- " //\n" \
- " //\n" \
- " //\n" \
- " if (controller._deferClose === -1) {\n" \
- " return;\n" \
- " }\n" \
- "\n" \
- " controller._deferClose = -1;\n" \
- " controller._deferFlush = -1;\n" \
- " var deferClose;\n" \
- " var deferFlush;\n" \
- "\n" \
- " //\n" \
- " //\n" \
- " //\n" \
- " //\n" \
- " //\n" \
- " //\n" \
- " try {\n" \
- " var result = controller.@underlyingSource.pull(controller);\n" \
- "\n" \
- " if (result && @isPromise(result)) {\n" \
- " if (controller._handleError === @undefined) {\n" \
- " controller._handleError =\n" \
- " @handleDirectStreamErrorReject.bind(controller);\n" \
- " }\n" \
- "\n" \
- " @Promise.prototype.catch.@call(result, controller._handleError);\n" \
- " }\n" \
- " } catch (e) {\n" \
- " return @handleDirectStreamErrorReject.@call(controller, e);\n" \
- " } finally {\n" \
- " deferClose = controller._deferClose;\n" \
- " deferFlush = controller._deferFlush;\n" \
- " controller._deferFlush = controller._deferClose = 0;\n" \
- " }\n" \
- "\n" \
- " var promiseToReturn;\n" \
- "\n" \
- " if (controller._pendingRead === @undefined) {\n" \
- " controller._pendingRead = promiseToReturn = @newPromise();\n" \
- " } else {\n" \
- " promiseToReturn = @readableStreamAddReadRequest(stream);\n" \
- " }\n" \
- "\n" \
- " //\n" \
- " //\n" \
- " if (deferClose === 1) {\n" \
- " var reason = controller._deferCloseReason;\n" \
- " controller._deferCloseReason = @undefined;\n" \
- " @onCloseDirectStream.@call(controller, reason);\n" \
- " return promiseToReturn;\n" \
- " }\n" \
- "\n" \
- " //\n" \
- " if (deferFlush === 1) {\n" \
- " @onFlushDirectStream.@call(controller);\n" \
- " }\n" \
- "\n" \
- " return promiseToReturn;\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsNoopDoneFunctionCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsNoopDoneFunctionCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsNoopDoneFunctionCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsNoopDoneFunctionCodeLength = 81;
-static const JSC::Intrinsic s_readableStreamInternalsNoopDoneFunctionCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsNoopDoneFunctionCode =
- "(function () {\n" \
- " return @Promise.@resolve({ value: @undefined, done: true });\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsOnReadableStreamDirectControllerClosedCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsOnReadableStreamDirectControllerClosedCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsOnReadableStreamDirectControllerClosedCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsOnReadableStreamDirectControllerClosedCodeLength = 107;
-static const JSC::Intrinsic s_readableStreamInternalsOnReadableStreamDirectControllerClosedCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsOnReadableStreamDirectControllerClosedCode =
- "(function (reason) {\n" \
- " \"use strict\";\n" \
- " @throwTypeError(\"ReadableStreamDirectController is now closed\");\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsOnCloseDirectStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsOnCloseDirectStreamCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsOnCloseDirectStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsOnCloseDirectStreamCodeLength = 2190;
-static const JSC::Intrinsic s_readableStreamInternalsOnCloseDirectStreamCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsOnCloseDirectStreamCode =
- "(function (reason) {\n" \
- " \"use strict\";\n" \
- " var stream = this.@controlledReadableStream;\n" \
- " if (!stream || @getByIdDirectPrivate(stream, \"state\") !== @streamReadable)\n" \
- " return;\n" \
- "\n" \
- " if (this._deferClose !== 0) {\n" \
- " this._deferClose = 1;\n" \
- " this._deferCloseReason = reason;\n" \
- " return;\n" \
- " }\n" \
- "\n" \
- " @putByIdDirectPrivate(stream, \"state\", @streamClosing);\n" \
- " if (typeof this.@underlyingSource.close === \"function\") {\n" \
- " try {\n" \
- " this.@underlyingSource.close.@call(this.@underlyingSource, reason);\n" \
- " } catch (e) {}\n" \
- " }\n" \
- "\n" \
- " var flushed;\n" \
- " try {\n" \
- " flushed = this.@sink.end();\n" \
- " @putByIdDirectPrivate(this, \"sink\", @undefined);\n" \
- " } catch (e) {\n" \
- " if (this._pendingRead) {\n" \
- " var read = this._pendingRead;\n" \
- " this._pendingRead = @undefined;\n" \
- " @rejectPromise(read, e);\n" \
- " }\n" \
- " @readableStreamError(stream, e);\n" \
- " return;\n" \
- " }\n" \
- "\n" \
- " this.error =\n" \
- " this.flush =\n" \
- " this.write =\n" \
- " this.close =\n" \
- " this.end =\n" \
- " @onReadableStreamDirectControllerClosed;\n" \
- "\n" \
- " var reader = @getByIdDirectPrivate(stream, \"reader\");\n" \
- "\n" \
- " if (reader && @isReadableStreamDefaultReader(reader)) {\n" \
- " var _pendingRead = this._pendingRead;\n" \
- " if (_pendingRead && @isPromise(_pendingRead) && flushed?.byteLength) {\n" \
- " this._pendingRead = @undefined;\n" \
- " @fulfillPromise(_pendingRead, { value: flushed, done: false });\n" \
- " @readableStreamClose(stream);\n" \
- " return;\n" \
- " }\n" \
- " }\n" \
- "\n" \
- " if (flushed?.byteLength) {\n" \
- " var requests = @getByIdDirectPrivate(reader, \"readRequests\");\n" \
- " if (requests?.isNotEmpty()) {\n" \
- " @readableStreamFulfillReadRequest(stream, flushed, false);\n" \
- " @readableStreamClose(stream);\n" \
- " return;\n" \
- " }\n" \
- "\n" \
- " @putByIdDirectPrivate(stream, \"state\", @streamReadable);\n" \
- " this.@pull = () => {\n" \
- " var thisResult = @createFulfilledPromise({\n" \
- " value: flushed,\n" \
- " done: false,\n" \
- " });\n" \
- " flushed = @undefined;\n" \
- " @readableStreamClose(stream);\n" \
- " stream = @undefined;\n" \
- " return thisResult;\n" \
- " };\n" \
- " } else if (this._pendingRead) {\n" \
- " var read = this._pendingRead;\n" \
- " this._pendingRead = @undefined;\n" \
- " @putByIdDirectPrivate(this, \"pull\", @noopDoneFunction);\n" \
- " @fulfillPromise(read, { value: @undefined, done: true });\n" \
- " }\n" \
- "\n" \
- " @readableStreamClose(stream);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsOnFlushDirectStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsOnFlushDirectStreamCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsOnFlushDirectStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsOnFlushDirectStreamCodeLength = 929;
-static const JSC::Intrinsic s_readableStreamInternalsOnFlushDirectStreamCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsOnFlushDirectStreamCode =
- "(function () {\n" \
- " \"use strict\";\n" \
- "\n" \
- " var stream = this.@controlledReadableStream;\n" \
- " var reader = @getByIdDirectPrivate(stream, \"reader\");\n" \
- " if (!reader || !@isReadableStreamDefaultReader(reader)) {\n" \
- " return;\n" \
- " }\n" \
- "\n" \
- " var _pendingRead = this._pendingRead;\n" \
- " this._pendingRead = @undefined;\n" \
- " if (_pendingRead && @isPromise(_pendingRead)) {\n" \
- " var flushed = this.@sink.flush();\n" \
- " if (flushed?.byteLength) {\n" \
- " this._pendingRead = @getByIdDirectPrivate(\n" \
- " stream,\n" \
- " \"readRequests\"\n" \
- " )?.shift();\n" \
- " @fulfillPromise(_pendingRead, { value: flushed, done: false });\n" \
- " } else {\n" \
- " this._pendingRead = _pendingRead;\n" \
- " }\n" \
- " } else if (@getByIdDirectPrivate(stream, \"readRequests\")?.isNotEmpty()) {\n" \
- " var flushed = this.@sink.flush();\n" \
- " if (flushed?.byteLength) {\n" \
- " @readableStreamFulfillReadRequest(stream, flushed, false);\n" \
- " }\n" \
- " } else if (this._deferFlush === -1) {\n" \
- " this._deferFlush = 1;\n" \
- " }\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsCreateTextStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsCreateTextStreamCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsCreateTextStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsCreateTextStreamCodeLength = 2373;
-static const JSC::Intrinsic s_readableStreamInternalsCreateTextStreamCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsCreateTextStreamCode =
- "(function (highWaterMark) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " var sink;\n" \
- " var array = [];\n" \
- " var hasString = false;\n" \
- " var hasBuffer = false;\n" \
- " var rope = \"\";\n" \
- " var estimatedLength = @toLength(0);\n" \
- " var capability = @newPromiseCapability(@Promise);\n" \
- " var calledDone = false;\n" \
- "\n" \
- " sink = {\n" \
- " start() {},\n" \
- " write(chunk) {\n" \
- " if (typeof chunk === \"string\") {\n" \
- " var chunkLength = @toLength(chunk.length);\n" \
- " if (chunkLength > 0) {\n" \
- " rope += chunk;\n" \
- " hasString = true;\n" \
- " //\n" \
- " estimatedLength += chunkLength;\n" \
- " }\n" \
- "\n" \
- " return chunkLength;\n" \
- " }\n" \
- "\n" \
- " if (\n" \
- " !chunk ||\n" \
- " !(@ArrayBuffer.@isView(chunk) || chunk instanceof @ArrayBuffer)\n" \
- " ) {\n" \
- " @throwTypeError(\"Expected text, ArrayBuffer or ArrayBufferView\");\n" \
- " }\n" \
- "\n" \
- " const byteLength = @toLength(chunk.byteLength);\n" \
- " if (byteLength > 0) {\n" \
- " hasBuffer = true;\n" \
- " if (rope.length > 0) {\n" \
- " @arrayPush(array, rope, chunk);\n" \
- " rope = \"\";\n" \
- " } else {\n" \
- " @arrayPush(array, chunk);\n" \
- " }\n" \
- " }\n" \
- " estimatedLength += byteLength;\n" \
- " return byteLength;\n" \
- " },\n" \
- "\n" \
- " flush() {\n" \
- " return 0;\n" \
- " },\n" \
- "\n" \
- " end() {\n" \
- " if (calledDone) {\n" \
- " return \"\";\n" \
- " }\n" \
- " return sink.fulfill();\n" \
- " },\n" \
- "\n" \
- " fulfill() {\n" \
- " calledDone = true;\n" \
- " const result = sink.finishInternal();\n" \
- "\n" \
- " @fulfillPromise(capability.@promise, result);\n" \
- " return result;\n" \
- " },\n" \
- "\n" \
- " finishInternal() {\n" \
- " if (!hasString && !hasBuffer) {\n" \
- " return \"\";\n" \
- " }\n" \
- "\n" \
- " if (hasString && !hasBuffer) {\n" \
- " return rope;\n" \
- " }\n" \
- "\n" \
- " if (hasBuffer && !hasString) {\n" \
- " return new globalThis.TextDecoder().decode(\n" \
- " @Bun.concatArrayBuffers(array)\n" \
- " );\n" \
- " }\n" \
- "\n" \
- " //\n" \
- "\n" \
- " var arrayBufferSink = new @Bun.ArrayBufferSink();\n" \
- " arrayBufferSink.start({\n" \
- " highWaterMark: estimatedLength,\n" \
- " asUint8Array: true,\n" \
- " });\n" \
- " for (let item of array) {\n" \
- " arrayBufferSink.write(item);\n" \
- " }\n" \
- " array.length = 0;\n" \
- " if (rope.length > 0) {\n" \
- " arrayBufferSink.write(rope);\n" \
- " rope = \"\";\n" \
- " }\n" \
- "\n" \
- " //\n" \
- " return new globalThis.TextDecoder().decode(arrayBufferSink.end());\n" \
- " },\n" \
- "\n" \
- " close() {\n" \
- " try {\n" \
- " if (!calledDone) {\n" \
- " calledDone = true;\n" \
- " sink.fulfill();\n" \
- " }\n" \
- " } catch (e) {}\n" \
- " },\n" \
- " };\n" \
- "\n" \
- " return [sink, capability];\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsInitializeTextStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsInitializeTextStreamCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsInitializeTextStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsInitializeTextStreamCodeLength = 822;
-static const JSC::Intrinsic s_readableStreamInternalsInitializeTextStreamCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsInitializeTextStreamCode =
- "(function (underlyingSource, highWaterMark) {\n" \
- " \"use strict\";\n" \
- " var [sink, closingPromise] = @createTextStream(highWaterMark);\n" \
- "\n" \
- " var controller = {\n" \
- " @underlyingSource: underlyingSource,\n" \
- " @pull: @onPullDirectStream,\n" \
- " @controlledReadableStream: this,\n" \
- " @sink: sink,\n" \
- " close: @onCloseDirectStream,\n" \
- " write: sink.write,\n" \
- " error: @handleDirectStreamError,\n" \
- " end: @onCloseDirectStream,\n" \
- " @close: @onCloseDirectStream,\n" \
- " flush: @onFlushDirectStream,\n" \
- " _pendingRead: @undefined,\n" \
- " _deferClose: 0,\n" \
- " _deferFlush: 0,\n" \
- " _deferCloseReason: @undefined,\n" \
- " _handleError: @undefined,\n" \
- " };\n" \
- "\n" \
- " @putByIdDirectPrivate(this, \"readableStreamController\", controller);\n" \
- " @putByIdDirectPrivate(this, \"underlyingSource\", @undefined);\n" \
- " @putByIdDirectPrivate(this, \"start\", @undefined);\n" \
- " return closingPromise;\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsInitializeArrayStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsInitializeArrayStreamCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsInitializeArrayStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsInitializeArrayStreamCodeLength = 1330;
-static const JSC::Intrinsic s_readableStreamInternalsInitializeArrayStreamCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsInitializeArrayStreamCode =
- "(function (underlyingSource, highWaterMark) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " var array = [];\n" \
- " var closingPromise = @newPromiseCapability(@Promise);\n" \
- " var calledDone = false;\n" \
- "\n" \
- " function fulfill() {\n" \
- " calledDone = true;\n" \
- " closingPromise.@resolve.@call(@undefined, array);\n" \
- " return array;\n" \
- " }\n" \
- "\n" \
- " var sink = {\n" \
- " start() {},\n" \
- " write(chunk) {\n" \
- " @arrayPush(array, chunk);\n" \
- " return chunk.byteLength || chunk.length;\n" \
- " },\n" \
- "\n" \
- " flush() {\n" \
- " return 0;\n" \
- " },\n" \
- "\n" \
- " end() {\n" \
- " if (calledDone) {\n" \
- " return [];\n" \
- " }\n" \
- " return fulfill();\n" \
- " },\n" \
- "\n" \
- " close() {\n" \
- " if (!calledDone) {\n" \
- " fulfill();\n" \
- " }\n" \
- " },\n" \
- " };\n" \
- "\n" \
- " var controller = {\n" \
- " @underlyingSource: underlyingSource,\n" \
- " @pull: @onPullDirectStream,\n" \
- " @controlledReadableStream: this,\n" \
- " @sink: sink,\n" \
- " close: @onCloseDirectStream,\n" \
- " write: sink.write,\n" \
- " error: @handleDirectStreamError,\n" \
- " end: @onCloseDirectStream,\n" \
- " @close: @onCloseDirectStream,\n" \
- " flush: @onFlushDirectStream,\n" \
- " _pendingRead: @undefined,\n" \
- " _deferClose: 0,\n" \
- " _deferFlush: 0,\n" \
- " _deferCloseReason: @undefined,\n" \
- " _handleError: @undefined,\n" \
- " };\n" \
- "\n" \
- " @putByIdDirectPrivate(this, \"readableStreamController\", controller);\n" \
- " @putByIdDirectPrivate(this, \"underlyingSource\", @undefined);\n" \
- " @putByIdDirectPrivate(this, \"start\", @undefined);\n" \
- " return closingPromise;\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsInitializeArrayBufferStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsInitializeArrayBufferStreamCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsInitializeArrayBufferStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsInitializeArrayBufferStreamCodeLength = 995;
-static const JSC::Intrinsic s_readableStreamInternalsInitializeArrayBufferStreamCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsInitializeArrayBufferStreamCode =
- "(function (underlyingSource, highWaterMark) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " //\n" \
- " //\n" \
- " //\n" \
- "\n" \
- " var opts =\n" \
- " highWaterMark && typeof highWaterMark === \"number\"\n" \
- " ? { highWaterMark, stream: true, asUint8Array: true }\n" \
- " : { stream: true, asUint8Array: true };\n" \
- " var sink = new @Bun.ArrayBufferSink();\n" \
- " sink.start(opts);\n" \
- "\n" \
- " var controller = {\n" \
- " @underlyingSource: underlyingSource,\n" \
- " @pull: @onPullDirectStream,\n" \
- " @controlledReadableStream: this,\n" \
- " @sink: sink,\n" \
- " close: @onCloseDirectStream,\n" \
- " write: sink.write.bind(sink),\n" \
- " error: @handleDirectStreamError,\n" \
- " end: @onCloseDirectStream,\n" \
- " @close: @onCloseDirectStream,\n" \
- " flush: @onFlushDirectStream,\n" \
- " _pendingRead: @undefined,\n" \
- " _deferClose: 0,\n" \
- " _deferFlush: 0,\n" \
- " _deferCloseReason: @undefined,\n" \
- " _handleError: @undefined,\n" \
- " };\n" \
- "\n" \
- " @putByIdDirectPrivate(this, \"readableStreamController\", controller);\n" \
- " @putByIdDirectPrivate(this, \"underlyingSource\", @undefined);\n" \
- " @putByIdDirectPrivate(this, \"start\", @undefined);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamErrorCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamErrorCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamErrorCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamErrorCodeLength = 1212;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamErrorCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamErrorCode =
- "(function (stream, error) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " @assert(@isReadableStream(stream));\n" \
- " @assert(@getByIdDirectPrivate(stream, \"state\") === @streamReadable);\n" \
- " @putByIdDirectPrivate(stream, \"state\", @streamErrored);\n" \
- " @putByIdDirectPrivate(stream, \"storedError\", error);\n" \
- "\n" \
- " const reader = @getByIdDirectPrivate(stream, \"reader\");\n" \
- "\n" \
- " if (!reader) return;\n" \
- "\n" \
- " if (@isReadableStreamDefaultReader(reader)) {\n" \
- " const requests = @getByIdDirectPrivate(reader, \"readRequests\");\n" \
- " @putByIdDirectPrivate(reader, \"readRequests\", @createFIFO());\n" \
- " for (var request = requests.shift(); request; request = requests.shift())\n" \
- " @rejectPromise(request, error);\n" \
- " } else {\n" \
- " @assert(@isReadableStreamBYOBReader(reader));\n" \
- " const requests = @getByIdDirectPrivate(reader, \"readIntoRequests\");\n" \
- " @putByIdDirectPrivate(reader, \"readIntoRequests\", @createFIFO());\n" \
- " for (var request = requests.shift(); request; request = requests.shift())\n" \
- " @rejectPromise(request, error);\n" \
- " }\n" \
- "\n" \
- " @getByIdDirectPrivate(reader, \"closedPromiseCapability\").@reject.@call(\n" \
- " @undefined,\n" \
- " error\n" \
- " );\n" \
- " const promise = @getByIdDirectPrivate(\n" \
- " reader,\n" \
- " \"closedPromiseCapability\"\n" \
- " ).@promise;\n" \
- " @markPromiseAsHandled(promise);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamDefaultControllerShouldCallPullCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamDefaultControllerShouldCallPullCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamDefaultControllerShouldCallPullCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamDefaultControllerShouldCallPullCodeLength = 700;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamDefaultControllerShouldCallPullCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamDefaultControllerShouldCallPullCode =
- "(function (controller) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " const stream = @getByIdDirectPrivate(controller, \"controlledReadableStream\");\n" \
- "\n" \
- " if (!@readableStreamDefaultControllerCanCloseOrEnqueue(controller))\n" \
- " return false;\n" \
- " if (!(@getByIdDirectPrivate(controller, \"started\") === 1)) return false;\n" \
- " if (\n" \
- " (!@isReadableStreamLocked(stream) ||\n" \
- " !@getByIdDirectPrivate(\n" \
- " @getByIdDirectPrivate(stream, \"reader\"),\n" \
- " \"readRequests\"\n" \
- " )?.isNotEmpty()) &&\n" \
- " @readableStreamDefaultControllerGetDesiredSize(controller) <= 0\n" \
- " )\n" \
- " return false;\n" \
- " const desiredSize =\n" \
- " @readableStreamDefaultControllerGetDesiredSize(controller);\n" \
- " @assert(desiredSize !== null);\n" \
- " return desiredSize > 0;\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamDefaultControllerCallPullIfNeededCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamDefaultControllerCallPullIfNeededCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamDefaultControllerCallPullIfNeededCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamDefaultControllerCallPullIfNeededCodeLength = 1277;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamDefaultControllerCallPullIfNeededCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamDefaultControllerCallPullIfNeededCode =
- "(function (controller) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " //\n" \
- " const stream = @getByIdDirectPrivate(controller, \"controlledReadableStream\");\n" \
- "\n" \
- " if (!@readableStreamDefaultControllerCanCloseOrEnqueue(controller)) return;\n" \
- " if (!(@getByIdDirectPrivate(controller, \"started\") === 1)) return;\n" \
- " if (\n" \
- " (!@isReadableStreamLocked(stream) ||\n" \
- " !@getByIdDirectPrivate(\n" \
- " @getByIdDirectPrivate(stream, \"reader\"),\n" \
- " \"readRequests\"\n" \
- " )?.isNotEmpty()) &&\n" \
- " @readableStreamDefaultControllerGetDesiredSize(controller) <= 0\n" \
- " )\n" \
- " return;\n" \
- "\n" \
- " if (@getByIdDirectPrivate(controller, \"pulling\")) {\n" \
- " @putByIdDirectPrivate(controller, \"pullAgain\", true);\n" \
- " return;\n" \
- " }\n" \
- "\n" \
- " @assert(!@getByIdDirectPrivate(controller, \"pullAgain\"));\n" \
- " @putByIdDirectPrivate(controller, \"pulling\", true);\n" \
- "\n" \
- " @getByIdDirectPrivate(controller, \"pullAlgorithm\")\n" \
- " .@call(@undefined)\n" \
- " .@then(\n" \
- " function () {\n" \
- " @putByIdDirectPrivate(controller, \"pulling\", false);\n" \
- " if (@getByIdDirectPrivate(controller, \"pullAgain\")) {\n" \
- " @putByIdDirectPrivate(controller, \"pullAgain\", false);\n" \
- "\n" \
- " @readableStreamDefaultControllerCallPullIfNeeded(controller);\n" \
- " }\n" \
- " },\n" \
- " function (error) {\n" \
- " @readableStreamDefaultControllerError(controller, error);\n" \
- " }\n" \
- " );\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsIsReadableStreamLockedCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsIsReadableStreamLockedCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsIsReadableStreamLockedCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsIsReadableStreamLockedCodeLength = 131;
-static const JSC::Intrinsic s_readableStreamInternalsIsReadableStreamLockedCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsIsReadableStreamLockedCode =
- "(function (stream) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " @assert(@isReadableStream(stream));\n" \
- " return !!@getByIdDirectPrivate(stream, \"reader\");\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamDefaultControllerGetDesiredSizeCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamDefaultControllerGetDesiredSizeCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamDefaultControllerGetDesiredSizeCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamDefaultControllerGetDesiredSizeCodeLength = 403;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamDefaultControllerGetDesiredSizeCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamDefaultControllerGetDesiredSizeCode =
- "(function (controller) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " const stream = @getByIdDirectPrivate(controller, \"controlledReadableStream\");\n" \
- " const state = @getByIdDirectPrivate(stream, \"state\");\n" \
- "\n" \
- " if (state === @streamErrored) return null;\n" \
- " if (state === @streamClosed) return 0;\n" \
- "\n" \
- " return (\n" \
- " @getByIdDirectPrivate(controller, \"strategy\").highWaterMark -\n" \
- " @getByIdDirectPrivate(controller, \"queue\").size\n" \
- " );\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamReaderGenericCancelCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamReaderGenericCancelCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamReaderGenericCancelCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamReaderGenericCancelCodeLength = 189;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamReaderGenericCancelCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamReaderGenericCancelCode =
- "(function (reader, reason) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " const stream = @getByIdDirectPrivate(reader, \"ownerReadableStream\");\n" \
- " @assert(!!stream);\n" \
- " return @readableStreamCancel(stream, reason);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamCancelCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamCancelCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamCancelCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamCancelCodeLength = 736;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamCancelCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamCancelCode =
- "(function (stream, reason) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " @putByIdDirectPrivate(stream, \"disturbed\", true);\n" \
- " const state = @getByIdDirectPrivate(stream, \"state\");\n" \
- " if (state === @streamClosed) return @Promise.@resolve();\n" \
- " if (state === @streamErrored)\n" \
- " return @Promise.@reject(@getByIdDirectPrivate(stream, \"storedError\"));\n" \
- " @readableStreamClose(stream);\n" \
- "\n" \
- " var controller = @getByIdDirectPrivate(stream, \"readableStreamController\");\n" \
- " var cancel = controller.@cancel;\n" \
- " if (cancel) {\n" \
- " return cancel(controller, reason).@then(function () {});\n" \
- " }\n" \
- "\n" \
- " var close = controller.close;\n" \
- " if (close) {\n" \
- " return @Promise.@resolve(controller.close(reason));\n" \
- " }\n" \
- "\n" \
- " @throwTypeError(\"ReadableStreamController has no cancel or close method\");\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamDefaultControllerCancelCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamDefaultControllerCancelCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamDefaultControllerCancelCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamDefaultControllerCancelCodeLength = 213;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamDefaultControllerCancelCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamDefaultControllerCancelCode =
- "(function (controller, reason) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " @putByIdDirectPrivate(controller, \"queue\", @newQueue());\n" \
- " return @getByIdDirectPrivate(controller, \"cancelAlgorithm\").@call(\n" \
- " @undefined,\n" \
- " reason\n" \
- " );\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamDefaultControllerPullCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamDefaultControllerPullCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamDefaultControllerPullCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamDefaultControllerPullCodeLength = 751;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamDefaultControllerPullCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamDefaultControllerPullCode =
- "(function (controller) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " var queue = @getByIdDirectPrivate(controller, \"queue\");\n" \
- " if (queue.content.isNotEmpty()) {\n" \
- " const chunk = @dequeueValue(queue);\n" \
- " if (\n" \
- " @getByIdDirectPrivate(controller, \"closeRequested\") &&\n" \
- " queue.content.isEmpty()\n" \
- " )\n" \
- " @readableStreamClose(\n" \
- " @getByIdDirectPrivate(controller, \"controlledReadableStream\")\n" \
- " );\n" \
- " else @readableStreamDefaultControllerCallPullIfNeeded(controller);\n" \
- "\n" \
- " return @createFulfilledPromise({ value: chunk, done: false });\n" \
- " }\n" \
- " const pendingPromise = @readableStreamAddReadRequest(\n" \
- " @getByIdDirectPrivate(controller, \"controlledReadableStream\")\n" \
- " );\n" \
- " @readableStreamDefaultControllerCallPullIfNeeded(controller);\n" \
- " return pendingPromise;\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamDefaultControllerCloseCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamDefaultControllerCloseCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamDefaultControllerCloseCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamDefaultControllerCloseCodeLength = 351;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamDefaultControllerCloseCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamDefaultControllerCloseCode =
- "(function (controller) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " @assert(@readableStreamDefaultControllerCanCloseOrEnqueue(controller));\n" \
- " @putByIdDirectPrivate(controller, \"closeRequested\", true);\n" \
- " if (@getByIdDirectPrivate(controller, \"queue\")?.content?.isEmpty())\n" \
- " @readableStreamClose(\n" \
- " @getByIdDirectPrivate(controller, \"controlledReadableStream\")\n" \
- " );\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamCloseCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamCloseCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamCloseCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamCloseCodeLength = 883;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamCloseCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamCloseCode =
- "(function (stream) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " @assert(@getByIdDirectPrivate(stream, \"state\") === @streamReadable);\n" \
- " @putByIdDirectPrivate(stream, \"state\", @streamClosed);\n" \
- " if (!@getByIdDirectPrivate(stream, \"reader\")) return;\n" \
- "\n" \
- " if (\n" \
- " @isReadableStreamDefaultReader(@getByIdDirectPrivate(stream, \"reader\"))\n" \
- " ) {\n" \
- " const requests = @getByIdDirectPrivate(\n" \
- " @getByIdDirectPrivate(stream, \"reader\"),\n" \
- " \"readRequests\"\n" \
- " );\n" \
- " if (requests.isNotEmpty()) {\n" \
- " @putByIdDirectPrivate(\n" \
- " @getByIdDirectPrivate(stream, \"reader\"),\n" \
- " \"readRequests\",\n" \
- " @createFIFO()\n" \
- " );\n" \
- "\n" \
- " for (var request = requests.shift(); request; request = requests.shift())\n" \
- " @fulfillPromise(request, { value: @undefined, done: true });\n" \
- " }\n" \
- " }\n" \
- "\n" \
- " @getByIdDirectPrivate(\n" \
- " @getByIdDirectPrivate(stream, \"reader\"),\n" \
- " \"closedPromiseCapability\"\n" \
- " ).@resolve.@call();\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamFulfillReadRequestCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamFulfillReadRequestCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamFulfillReadRequestCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamFulfillReadRequestCodeLength = 237;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamFulfillReadRequestCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamFulfillReadRequestCode =
- "(function (stream, chunk, done) {\n" \
- " \"use strict\";\n" \
- " const readRequest = @getByIdDirectPrivate(\n" \
- " @getByIdDirectPrivate(stream, \"reader\"),\n" \
- " \"readRequests\"\n" \
- " ).shift();\n" \
- " @fulfillPromise(readRequest, { value: chunk, done: done });\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamDefaultControllerEnqueueCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamDefaultControllerEnqueueCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamDefaultControllerEnqueueCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamDefaultControllerEnqueueCodeLength = 986;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamDefaultControllerEnqueueCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamDefaultControllerEnqueueCode =
- "(function (controller, chunk) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " const stream = @getByIdDirectPrivate(controller, \"controlledReadableStream\");\n" \
- " //\n" \
- " @assert(@readableStreamDefaultControllerCanCloseOrEnqueue(controller));\n" \
- "\n" \
- " if (\n" \
- " @isReadableStreamLocked(stream) &&\n" \
- " @getByIdDirectPrivate(\n" \
- " @getByIdDirectPrivate(stream, \"reader\"),\n" \
- " \"readRequests\"\n" \
- " )?.isNotEmpty()\n" \
- " ) {\n" \
- " @readableStreamFulfillReadRequest(stream, chunk, false);\n" \
- " @readableStreamDefaultControllerCallPullIfNeeded(controller);\n" \
- " return;\n" \
- " }\n" \
- "\n" \
- " try {\n" \
- " let chunkSize = 1;\n" \
- " if (@getByIdDirectPrivate(controller, \"strategy\").size !== @undefined)\n" \
- " chunkSize = @getByIdDirectPrivate(controller, \"strategy\").size(chunk);\n" \
- " @enqueueValueWithSize(\n" \
- " @getByIdDirectPrivate(controller, \"queue\"),\n" \
- " chunk,\n" \
- " chunkSize\n" \
- " );\n" \
- " } catch (error) {\n" \
- " @readableStreamDefaultControllerError(controller, error);\n" \
- " throw error;\n" \
- " }\n" \
- " @readableStreamDefaultControllerCallPullIfNeeded(controller);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamDefaultReaderReadCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamDefaultReaderReadCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamDefaultReaderReadCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamDefaultReaderReadCodeLength = 631;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamDefaultReaderReadCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamDefaultReaderReadCode =
- "(function (reader) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " const stream = @getByIdDirectPrivate(reader, \"ownerReadableStream\");\n" \
- " @assert(!!stream);\n" \
- " const state = @getByIdDirectPrivate(stream, \"state\");\n" \
- "\n" \
- " @putByIdDirectPrivate(stream, \"disturbed\", true);\n" \
- " if (state === @streamClosed)\n" \
- " return @createFulfilledPromise({ value: @undefined, done: true });\n" \
- " if (state === @streamErrored)\n" \
- " return @Promise.@reject(@getByIdDirectPrivate(stream, \"storedError\"));\n" \
- " @assert(state === @streamReadable);\n" \
- "\n" \
- " return @getByIdDirectPrivate(stream, \"readableStreamController\").@pull(\n" \
- " @getByIdDirectPrivate(stream, \"readableStreamController\")\n" \
- " );\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamAddReadRequestCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamAddReadRequestCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamAddReadRequestCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamAddReadRequestCodeLength = 377;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamAddReadRequestCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamAddReadRequestCode =
- "(function (stream) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " @assert(\n" \
- " @isReadableStreamDefaultReader(@getByIdDirectPrivate(stream, \"reader\"))\n" \
- " );\n" \
- " @assert(@getByIdDirectPrivate(stream, \"state\") == @streamReadable);\n" \
- "\n" \
- " const readRequest = @newPromise();\n" \
- "\n" \
- " @getByIdDirectPrivate(\n" \
- " @getByIdDirectPrivate(stream, \"reader\"),\n" \
- " \"readRequests\"\n" \
- " ).push(readRequest);\n" \
- "\n" \
- " return readRequest;\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsIsReadableStreamDisturbedCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsIsReadableStreamDisturbedCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsIsReadableStreamDisturbedCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsIsReadableStreamDisturbedCodeLength = 132;
-static const JSC::Intrinsic s_readableStreamInternalsIsReadableStreamDisturbedCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsIsReadableStreamDisturbedCode =
- "(function (stream) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " @assert(@isReadableStream(stream));\n" \
- " return @getByIdDirectPrivate(stream, \"disturbed\");\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamReaderGenericReleaseCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamReaderGenericReleaseCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamReaderGenericReleaseCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamReaderGenericReleaseCodeLength = 1083;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamReaderGenericReleaseCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamReaderGenericReleaseCode =
- "(function (reader) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " @assert(!!@getByIdDirectPrivate(reader, \"ownerReadableStream\"));\n" \
- " @assert(\n" \
- " @getByIdDirectPrivate(\n" \
- " @getByIdDirectPrivate(reader, \"ownerReadableStream\"),\n" \
- " \"reader\"\n" \
- " ) === reader\n" \
- " );\n" \
- "\n" \
- " if (\n" \
- " @getByIdDirectPrivate(\n" \
- " @getByIdDirectPrivate(reader, \"ownerReadableStream\"),\n" \
- " \"state\"\n" \
- " ) === @streamReadable\n" \
- " )\n" \
- " @getByIdDirectPrivate(reader, \"closedPromiseCapability\").@reject.@call(\n" \
- " @undefined,\n" \
- " @makeTypeError(\n" \
- " \"releasing lock of reader whose stream is still in readable state\"\n" \
- " )\n" \
- " );\n" \
- " else\n" \
- " @putByIdDirectPrivate(reader, \"closedPromiseCapability\", {\n" \
- " @promise: @newHandledRejectedPromise(\n" \
- " @makeTypeError(\"reader released lock\")\n" \
- " ),\n" \
- " });\n" \
- "\n" \
- " const promise = @getByIdDirectPrivate(\n" \
- " reader,\n" \
- " \"closedPromiseCapability\"\n" \
- " ).@promise;\n" \
- " @markPromiseAsHandled(promise);\n" \
- " @putByIdDirectPrivate(\n" \
- " @getByIdDirectPrivate(reader, \"ownerReadableStream\"),\n" \
- " \"reader\",\n" \
- " @undefined\n" \
- " );\n" \
- " @putByIdDirectPrivate(reader, \"ownerReadableStream\", @undefined);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamDefaultControllerCanCloseOrEnqueueCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamDefaultControllerCanCloseOrEnqueueCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamDefaultControllerCanCloseOrEnqueueCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamDefaultControllerCanCloseOrEnqueueCodeLength = 257;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamDefaultControllerCanCloseOrEnqueueCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamDefaultControllerCanCloseOrEnqueueCode =
- "(function (controller) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " return (\n" \
- " !@getByIdDirectPrivate(controller, \"closeRequested\") &&\n" \
- " @getByIdDirectPrivate(\n" \
- " @getByIdDirectPrivate(controller, \"controlledReadableStream\"),\n" \
- " \"state\"\n" \
- " ) === @streamReadable\n" \
- " );\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsLazyLoadStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsLazyLoadStreamCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsLazyLoadStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsLazyLoadStreamCodeLength = 3983;
-static const JSC::Intrinsic s_readableStreamInternalsLazyLoadStreamCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsLazyLoadStreamCode =
- "(function (stream, autoAllocateChunkSize) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " var nativeType = @getByIdDirectPrivate(stream, \"bunNativeType\");\n" \
- " var nativePtr = @getByIdDirectPrivate(stream, \"bunNativePtr\");\n" \
- " var Prototype = @lazyStreamPrototypeMap.@get(nativeType);\n" \
- " if (Prototype === @undefined) {\n" \
- " var [pull, start, cancel, setClose, deinit, setRefOrUnref, drain] = @lazyLoad(nativeType);\n" \
- " var closer = [false];\n" \
- " var handleResult;\n" \
- " function handleNativeReadableStreamPromiseResult(val) {\n" \
- " \"use strict\";\n" \
- " var { c, v } = this;\n" \
- " this.c = @undefined;\n" \
- " this.v = @undefined;\n" \
- " handleResult(val, c, v);\n" \
- " }\n" \
- "\n" \
- " function callClose(controller) {\n" \
- " try {\n" \
- " controller.close();\n" \
- " } catch(e) {\n" \
- " globalThis.reportError(e);\n" \
- " }\n" \
- " }\n" \
- "\n" \
- " handleResult = function handleResult(result, controller, view) {\n" \
- " \"use strict\";\n" \
- " if (result && @isPromise(result)) {\n" \
- " return result.then(\n" \
- " handleNativeReadableStreamPromiseResult.bind({\n" \
- " c: controller,\n" \
- " v: view,\n" \
- " }),\n" \
- " (err) => controller.error(err)\n" \
- " );\n" \
- " } else if (typeof result === 'number') {\n" \
- " if (view && view.byteLength === result && view.buffer === controller.byobRequest?.view?.buffer) {\n" \
- " controller.byobRequest.respondWithNewView(view);\n" \
- " } else {\n" \
- " controller.byobRequest.respond(result);\n" \
- " }\n" \
- " } else if (result.constructor === @Uint8Array) {\n" \
- " controller.enqueue(result);\n" \
- " }\n" \
- "\n" \
- " if (closer[0] || result === false) {\n" \
- " @enqueueJob(callClose, controller);\n" \
- " closer[0] = false;\n" \
- " }\n" \
- " };\n" \
- "\n" \
- " function createResult(tag, controller, view, closer) {\n" \
- " closer[0] = false;\n" \
- "\n" \
- " var result;\n" \
- " try {\n" \
- " result = pull(tag, view, closer);\n" \
- " } catch (err) {\n" \
- " return controller.error(err);\n" \
- " }\n" \
- "\n" \
- " return handleResult(result, controller, view);\n" \
- " }\n" \
- "\n" \
- " const registry = deinit ? new FinalizationRegistry(deinit) : null;\n" \
- " Prototype = class NativeReadableStreamSource {\n" \
- " constructor(tag, autoAllocateChunkSize, drainValue) {\n" \
- " this.#tag = tag;\n" \
- " this.#cancellationToken = {};\n" \
- " this.pull = this.#pull.bind(this);\n" \
- " this.cancel = this.#cancel.bind(this);\n" \
- " this.autoAllocateChunkSize = autoAllocateChunkSize;\n" \
- "\n" \
- " if (drainValue !== @undefined) {\n" \
- " this.start = (controller) => {\n" \
- " controller.enqueue(drainValue);\n" \
- " };\n" \
- " }\n" \
- "\n" \
- " if (registry) {\n" \
- " registry.register(this, tag, this.#cancellationToken);\n" \
- " }\n" \
- " }\n" \
- "\n" \
- " #cancellationToken;\n" \
- " pull;\n" \
- " cancel;\n" \
- " start;\n" \
- "\n" \
- " #tag;\n" \
- " type = \"bytes\";\n" \
- " autoAllocateChunkSize = 0;\n" \
- " \n" \
- " static startSync = start;\n" \
- " \n" \
- " \n" \
- " #pull(controller) {\n" \
- " var tag = this.#tag;\n" \
- "\n" \
- " if (!tag) {\n" \
- " controller.close();\n" \
- " return;\n" \
- " }\n" \
- "\n" \
- " createResult(tag, controller, controller.byobRequest.view, closer);\n" \
- " }\n" \
- "\n" \
- " #cancel(reason) {\n" \
- " var tag = this.#tag;\n" \
- "\n" \
- " registry && registry.unregister(this.#cancellationToken);\n" \
- " setRefOrUnref && setRefOrUnref(tag, false);\n" \
- " cancel(tag, reason);\n" \
- " }\n" \
- " static deinit = deinit;\n" \
- " static drain = drain;\n" \
- " };\n" \
- " @lazyStreamPrototypeMap.@set(nativeType, Prototype);\n" \
- " }\n" \
- "\n" \
- " const chunkSize = Prototype.startSync(nativePtr, autoAllocateChunkSize);\n" \
- " var drainValue;\n" \
- " const {drain: drainFn, deinit: deinitFn} = Prototype;\n" \
- " if (drainFn) {\n" \
- " drainValue = drainFn(nativePtr);\n" \
- " }\n" \
- "\n" \
- " //\n" \
- " if (chunkSize === 0) {\n" \
- " deinit && nativePtr && @enqueueJob(deinit, nativePtr);\n" \
- "\n" \
- " if ((drainValue?.byteLength ?? 0) > 0) {\n" \
- " return {\n" \
- " start(controller) {\n" \
- " controller.enqueue(drainValue);\n" \
- " controller.close();\n" \
- " },\n" \
- " type: \"bytes\",\n" \
- " };\n" \
- " }\n" \
- "\n" \
- " return {\n" \
- " start(controller) {\n" \
- " controller.close();\n" \
- " },\n" \
- " type: \"bytes\",\n" \
- " };\n" \
- " }\n" \
- "\n" \
- " return new Prototype(nativePtr, chunkSize, drainValue);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamIntoArrayCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamIntoArrayCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamIntoArrayCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamIntoArrayCodeLength = 578;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamIntoArrayCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamIntoArrayCode =
- "(function (stream) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " var reader = stream.getReader();\n" \
- " var manyResult = reader.readMany();\n" \
- "\n" \
- " async function processManyResult(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" \
- " break;\n" \
- " }\n" \
- " chunks = chunks.concat(thisResult.value);\n" \
- " }\n" \
- "\n" \
- " return chunks;\n" \
- " }\n" \
- "\n" \
- " if (manyResult && @isPromise(manyResult)) {\n" \
- " return manyResult.@then(processManyResult);\n" \
- " }\n" \
- "\n" \
- " return processManyResult(manyResult);\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamIntoTextCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamIntoTextCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamIntoTextCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamIntoTextCodeLength = 333;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamIntoTextCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamIntoTextCode =
- "(function (stream) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " const [textStream, closer] = @createTextStream(\n" \
- " @getByIdDirectPrivate(stream, \"highWaterMark\")\n" \
- " );\n" \
- " const prom = @readStreamIntoSink(stream, textStream, false);\n" \
- " if (prom && @isPromise(prom)) {\n" \
- " return @Promise.@resolve(prom).@then(closer.@promise);\n" \
- " }\n" \
- " return closer.@promise;\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamToArrayBufferDirectCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamToArrayBufferDirectCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamToArrayBufferDirectCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamToArrayBufferDirectCodeLength = 1533;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamToArrayBufferDirectCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamToArrayBufferDirectCode =
- "(function (stream, underlyingSource) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " var sink = new @Bun.ArrayBufferSink();\n" \
- " @putByIdDirectPrivate(stream, \"underlyingSource\", @undefined);\n" \
- " var highWaterMark = @getByIdDirectPrivate(stream, \"highWaterMark\");\n" \
- " sink.start(highWaterMark ? { highWaterMark } : {});\n" \
- " var capability = @newPromiseCapability(@Promise);\n" \
- " var ended = false;\n" \
- " var pull = underlyingSource.pull;\n" \
- " var close = underlyingSource.close;\n" \
- "\n" \
- " var controller = {\n" \
- " start() {},\n" \
- " close(reason) {\n" \
- " if (!ended) {\n" \
- " ended = true;\n" \
- " if (close) {\n" \
- " close();\n" \
- " }\n" \
- "\n" \
- " @fulfillPromise(capability.@promise, sink.end());\n" \
- " }\n" \
- " },\n" \
- " end() {\n" \
- " if (!ended) {\n" \
- " ended = true;\n" \
- " if (close) {\n" \
- " close();\n" \
- " }\n" \
- " @fulfillPromise(capability.@promise, sink.end());\n" \
- " }\n" \
- " },\n" \
- " flush() {\n" \
- " return 0;\n" \
- " },\n" \
- " write: sink.write.bind(sink),\n" \
- " };\n" \
- "\n" \
- " var didError = false;\n" \
- " try {\n" \
- " const firstPull = pull(controller);\n" \
- " if (firstPull && @isObject(firstPull) && @isPromise(firstPull)) {\n" \
- " return (async function (controller, promise, pull) {\n" \
- " while (!ended) {\n" \
- " await pull(controller);\n" \
- " }\n" \
- " return await promise;\n" \
- " })(controller, promise, pull);\n" \
- " }\n" \
- "\n" \
- " return capability.@promise;\n" \
- " } catch (e) {\n" \
- " didError = true;\n" \
- " @readableStreamError(stream, e);\n" \
- " return @Promise.@reject(e);\n" \
- " } finally {\n" \
- " if (!didError && stream) @readableStreamClose(stream);\n" \
- " controller = close = sink = pull = stream = @undefined;\n" \
- " }\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamToTextDirectCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamToTextDirectCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamToTextDirectCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamToTextDirectCodeLength = 496;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamToTextDirectCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamToTextDirectCode =
- "(async function (stream, underlyingSource) {\n" \
- " \"use strict\";\n" \
- " const capability = @initializeTextStream.@call(\n" \
- " stream,\n" \
- " underlyingSource,\n" \
- " @undefined\n" \
- " );\n" \
- " var reader = stream.getReader();\n" \
- "\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" \
- " reader = @undefined;\n" \
- " stream = @undefined;\n" \
- "\n" \
- " return capability.@promise;\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamToArrayDirectCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamToArrayDirectCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamToArrayDirectCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamToArrayDirectCodeLength = 667;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamToArrayDirectCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamToArrayDirectCode =
- "(async function (stream, underlyingSource) {\n" \
- " const capability = @initializeArrayStream.@call(\n" \
- " stream,\n" \
- " underlyingSource,\n" \
- " @undefined\n" \
- " );\n" \
- " underlyingSource = @undefined;\n" \
- " var reader = stream.getReader();\n" \
- " try {\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" \
- " reader = @undefined;\n" \
- "\n" \
- " return @Promise.@resolve(capability.@promise);\n" \
- " } catch (e) {\n" \
- " throw e;\n" \
- " } finally {\n" \
- " stream = @undefined;\n" \
- " reader = @undefined;\n" \
- " }\n" \
- "\n" \
- " return capability.@promise;\n" \
- "})\n" \
-;
-
-const JSC::ConstructAbility s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
-const JSC::ConstructorKind s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeConstructorKind = JSC::ConstructorKind::None;
-const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeLength = 1478;
-static const JSC::Intrinsic s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeIntrinsic = JSC::NoIntrinsic;
-const char* const s_readableStreamInternalsReadableStreamDefineLazyIteratorsCode =
- "(function (prototype) {\n" \
- " \"use strict\";\n" \
- "\n" \
- " var asyncIterator = globalThis.Symbol.asyncIterator;\n" \
- "\n" \
- " var ReadableStreamAsyncIterator = async function* ReadableStreamAsyncIterator(stream, preventCancel) {\n" \
- " var reader = stream.getReader();\n" \
- " var deferredError;\n" \
- " try {\n" \
- " while (true) {\n" \
- " var done, value;\n" \
- " const firstResult = reader.readMany();\n" \
- " if (@isPromise(firstResult)) {\n" \
- " ({done, value} = await firstResult);\n" \
- " } else {\n" \
- " ({done, value} = firstResult);\n" \
- " }\n" \
- "\n" \
- " if (done) {\n" \
- " return;\n" \
- " }\n" \
- " yield* value;\n" \
- " }\n" \
- " } catch(e) {\n" \
- " deferredError = e;\n" \
- " } finally {\n" \
- " reader.releaseLock();\n" \
- "\n" \
- " if (!preventCancel) {\n" \
- " stream.cancel(deferredError);\n" \
- " }\n" \
- "\n" \
- " if (deferredError) {\n" \
- " throw deferredError;\n" \
- " }\n" \
- " }\n" \
- " };\n" \
- " var createAsyncIterator = function asyncIterator() {\n" \
- " return ReadableStreamAsyncIterator(this, false);\n" \
- " };\n" \
- " var createValues = function values({preventCancel = false} = {preventCancel: false}) {\n" \
- " return ReadableStreamAsyncIterator(this, preventCancel);\n" \
- " };\n" \
- " @Object.@defineProperty(prototype, asyncIterator, { value: createAsyncIterator });\n" \
- " @Object.@defineProperty(prototype, \"values\", { value: createValues });\n" \
- " return prototype;\n" \
- "})\n" \
-;
-
-
-#define DEFINE_BUILTIN_GENERATOR(codeName, functionName, overriddenName, argumentCount) \
-JSC::FunctionExecutable* codeName##Generator(JSC::VM& vm) \
-{\
- JSVMClientData* clientData = static_cast<JSVMClientData*>(vm.clientData); \
- return clientData->builtinFunctions().readableStreamInternalsBuiltins().codeName##Executable()->link(vm, nullptr, clientData->builtinFunctions().readableStreamInternalsBuiltins().codeName##Source(), std::nullopt, s_##codeName##Intrinsic); \
-}
-WEBCORE_FOREACH_READABLESTREAMINTERNALS_BUILTIN_CODE(DEFINE_BUILTIN_GENERATOR)
-#undef DEFINE_BUILTIN_GENERATOR
-
-
-} // namespace WebCore