diff options
author | 2022-10-12 23:50:48 -0700 | |
---|---|---|
committer | 2022-10-12 23:50:48 -0700 | |
commit | 22f7981cff6550fce88769164fbd2fcf9ba5129d (patch) | |
tree | db2b36c5f1458cef17f0c6c7582e8b6023f0a0c2 /src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp | |
parent | ad29d9ffb3340814ceda768ed60f5ea0a7a65ca4 (diff) | |
download | bun-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.cpp | 73 |
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) \ |