aboutsummaryrefslogtreecommitdiff
path: root/src/bun.js/builtins/cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/bun.js/builtins/cpp')
-rw-r--r--src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp15
-rw-r--r--src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp9
2 files changed, 12 insertions, 12 deletions
diff --git a/src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp b/src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp
index 52f8b5147..9504549e0 100644
--- a/src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp
+++ b/src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp
@@ -94,7 +94,7 @@ const char* const s_readableStreamDefaultReaderCancelCode =
const JSC::ConstructAbility s_readableStreamDefaultReaderReadManyCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
const JSC::ConstructorKind s_readableStreamDefaultReaderReadManyCodeConstructorKind = JSC::ConstructorKind::None;
const JSC::ImplementationVisibility s_readableStreamDefaultReaderReadManyCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_readableStreamDefaultReaderReadManyCodeLength = 4661;
+const int s_readableStreamDefaultReaderReadManyCodeLength = 4743;
static const JSC::Intrinsic s_readableStreamDefaultReaderReadManyCodeIntrinsic = JSC::NoIntrinsic;
const char* const s_readableStreamDefaultReaderReadManyCode =
"(function ()\n" \
@@ -126,11 +126,14 @@ const char* const s_readableStreamDefaultReaderReadManyCode =
" return controller.@pull(\n" \
" controller\n" \
" ).@then(\n" \
- " ({done, value}) => (\n" \
- " done ? \n" \
- " { done: true, value: [], size: 0 } : \n" \
- " { value: [value], size: 1, done: false }\n" \
- " ));\n" \
+ " function({done, value}) {\n" \
+ " return (\n" \
+ " done ? \n" \
+ " { done: true, value: [], size: 0 } : \n" \
+ " { value: [value], size: 1, done: false }\n" \
+ " );\n" \
+ " }\n" \
+ " );\n" \
" }\n" \
"\n" \
" const content = queue.content;\n" \
diff --git a/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp b/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp
index 4b65667cf..90b9eeada 100644
--- a/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp
+++ b/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp
@@ -986,7 +986,7 @@ const char* const s_readableStreamInternalsIsReadableStreamDefaultControllerCode
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 = 1582;
+const int s_readableStreamInternalsReadDirectStreamCodeLength = 1557;
static const JSC::Intrinsic s_readableStreamInternalsReadDirectStreamCodeIntrinsic = JSC::NoIntrinsic;
const char* const s_readableStreamInternalsReadDirectStreamCode =
"(function (stream, sink, underlyingSource) {\n" \
@@ -995,10 +995,6 @@ const char* const s_readableStreamInternalsReadDirectStreamCode =
" @putByIdDirectPrivate(stream, \"underlyingSource\", @undefined);\n" \
" @putByIdDirectPrivate(stream, \"start\", @undefined);\n" \
"\n" \
- "\n" \
- " var capturedStream = stream;\n" \
- " var reader;\n" \
- "\n" \
" function close(stream, reason) {\n" \
" if (reason && underlyingSource?.cancel) {\n" \
" try {\n" \
@@ -1019,7 +1015,7 @@ const char* const s_readableStreamInternalsReadDirectStreamCode =
" } else {\n" \
" @putByIdDirectPrivate(stream, \"state\", @streamClosed);\n" \
" }\n" \
- " \n" \
+ " stream = @undefined;\n" \
" }\n" \
" }\n" \
"\n" \
@@ -1056,6 +1052,7 @@ const char* const s_readableStreamInternalsReadDirectStreamCode =
" return maybePromise.@then(() => {});\n" \
" }\n" \
"\n" \
+ "\n" \
"})\n" \
;