aboutsummaryrefslogtreecommitdiff
path: root/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-10-12 23:50:48 -0700
committerGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-10-12 23:50:48 -0700
commit22f7981cff6550fce88769164fbd2fcf9ba5129d (patch)
treedb2b36c5f1458cef17f0c6c7582e8b6023f0a0c2 /src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp
parentad29d9ffb3340814ceda768ed60f5ea0a7a65ca4 (diff)
downloadbun-22f7981cff6550fce88769164fbd2fcf9ba5129d.tar.gz
bun-22f7981cff6550fce88769164fbd2fcf9ba5129d.tar.zst
bun-22f7981cff6550fce88769164fbd2fcf9ba5129d.zip
Regenerate builtins
Diffstat (limited to 'src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp')
-rw-r--r--src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp73
1 files changed, 71 insertions, 2 deletions
diff --git a/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp b/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp
index 751a2a895..f1cc09349 100644
--- a/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp
+++ b/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp
@@ -1938,7 +1938,7 @@ const char* const s_readableStreamInternalsReadableStreamReaderGenericCancelCode
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 = 505;
+const int s_readableStreamInternalsReadableStreamCancelCodeLength = 736;
static const JSC::Intrinsic s_readableStreamInternalsReadableStreamCancelCodeIntrinsic = JSC::NoIntrinsic;
const char* const s_readableStreamInternalsReadableStreamCancelCode =
"(function (stream, reason) {\n" \
@@ -1952,7 +1952,17 @@ const char* const s_readableStreamInternalsReadableStreamCancelCode =
" @readableStreamClose(stream);\n" \
"\n" \
" var controller = @getByIdDirectPrivate(stream, \"readableStreamController\");\n" \
- " return controller.@cancel(controller, reason).@then(function () {});\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" \
;
@@ -2555,6 +2565,65 @@ const char* const s_readableStreamInternalsReadableStreamToArrayDirectCode =
"})\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 = 1651;
+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" \
+ " const result = await firstResult;\n" \
+ " done = result.done;\n" \
+ " value = result.value;\n" \
+ " } else {\n" \
+ " done = firstResult.done;\n" \
+ " value = firstResult.value;\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" \
+ "\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) \