mild clean up

4 files changed, 22 insertions, 22 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" \
 ;
 
diff --git a/src/bun.js/builtins/js/ReadableStreamDefaultReader.js b/src/bun.js/builtins/js/ReadableStreamDefaultReader.js
index 4671f1458..77da965ed 100644
--- a/src/bun.js/builtins/js/ReadableStreamDefaultReader.js
+++ b/src/bun.js/builtins/js/ReadableStreamDefaultReader.js
@@ -80,11 +80,14 @@ function readMany()
         return controller.@pull(
             controller
         ).@then(
-            ({done, value}) => (
-                done ? 
-                { done: true, value: [], size: 0 } : 
-                { value: [value], size: 1, done: false }
-        ));
+            function({done, value}) {
+                return (
+                    done ? 
+                        { done: true, value: [], size: 0 } : 
+                        { value: [value], size: 1, done: false }
+                );
+            }
+        );
     }
 
     const content = queue.content;
diff --git a/src/bun.js/builtins/js/ReadableStreamInternals.js b/src/bun.js/builtins/js/ReadableStreamInternals.js
index c6115a456..e8c9667a0 100644
--- a/src/bun.js/builtins/js/ReadableStreamInternals.js
+++ b/src/bun.js/builtins/js/ReadableStreamInternals.js
@@ -795,10 +795,6 @@ function readDirectStream(stream, sink, underlyingSource) {
   @putByIdDirectPrivate(stream, "underlyingSource", @undefined);
   @putByIdDirectPrivate(stream, "start", @undefined);
 
-
-  var capturedStream = stream;
-  var reader;
-
   function close(stream, reason) {
     if (reason && underlyingSource?.cancel) {
       try {
@@ -819,7 +815,7 @@ function readDirectStream(stream, sink, underlyingSource) {
       } else {
         @putByIdDirectPrivate(stream, "state", @streamClosed);
       }
-      
+       stream = @undefined;
     }
   }
 
@@ -856,6 +852,7 @@ function readDirectStream(stream, sink, underlyingSource) {
     return maybePromise.@then(() => {});
   }
 
+
 }
 
 @linkTimeConstant;