Regenerate builtins

8 files changed, 452 insertions, 17 deletions

diff --git a/src/bun.js/builtins/cpp/ProcessObjectBuiltins.cpp b/src/bun.js/builtins/cpp/ProcessObjectBuiltins.cpp
new file mode 100644
index 000000000..18463bb9d
--- /dev/null
+++ b/src/bun.js/builtins/cpp/ProcessObjectBuiltins.cpp
@@ -0,0 +1,62 @@
+/*
+ * 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) 2022 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 "ProcessObjectBuiltins.h"
+
+#include "WebCoreJSClientData.h"
+#include <JavaScriptCore/HeapInlines.h>
+#include <JavaScriptCore/IdentifierInlines.h>
+#include <JavaScriptCore/ImplementationVisibility.h>
+#include <JavaScriptCore/Intrinsic.h>
+#include <JavaScriptCore/JSCJSValueInlines.h>
+#include <JavaScriptCore/JSCellInlines.h>
+#include <JavaScriptCore/StructureInlines.h>
+#include <JavaScriptCore/VM.h>
+
+namespace WebCore {
+
+
+#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().processObjectBuiltins().codeName##Executable()->link(vm, nullptr, clientData->builtinFunctions().processObjectBuiltins().codeName##Source(), std::nullopt, s_##codeName##Intrinsic); \
+}
+WEBCORE_FOREACH_PROCESSOBJECT_BUILTIN_CODE(DEFINE_BUILTIN_GENERATOR)
+#undef DEFINE_BUILTIN_GENERATOR
+
+
+} // namespace WebCore
diff --git a/src/bun.js/builtins/cpp/ProcessObjectBuiltins.h b/src/bun.js/builtins/cpp/ProcessObjectBuiltins.h
new file mode 100644
index 000000000..da852b83e
--- /dev/null
+++ b/src/bun.js/builtins/cpp/ProcessObjectBuiltins.h
@@ -0,0 +1,119 @@
+/*
+ * 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) 2022 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
+
+#pragma once
+
+#include <JavaScriptCore/BuiltinUtils.h>
+#include <JavaScriptCore/Identifier.h>
+#include <JavaScriptCore/JSFunction.h>
+#include <JavaScriptCore/UnlinkedFunctionExecutable.h>
+
+namespace JSC {
+class FunctionExecutable;
+}
+
+namespace WebCore {
+
+/* ProcessObject */
+
+#define WEBCORE_FOREACH_PROCESSOBJECT_BUILTIN_DATA(macro) \
+
+
+#define WEBCORE_FOREACH_PROCESSOBJECT_BUILTIN_CODE(macro) \
+
+#define WEBCORE_FOREACH_PROCESSOBJECT_BUILTIN_FUNCTION_NAME(macro) \
+
+#define DECLARE_BUILTIN_GENERATOR(codeName, functionName, overriddenName, argumentCount) \
+    JSC::FunctionExecutable* codeName##Generator(JSC::VM&);
+
+WEBCORE_FOREACH_PROCESSOBJECT_BUILTIN_CODE(DECLARE_BUILTIN_GENERATOR)
+#undef DECLARE_BUILTIN_GENERATOR
+
+class ProcessObjectBuiltinsWrapper : private JSC::WeakHandleOwner {
+public:
+    explicit ProcessObjectBuiltinsWrapper(JSC::VM& vm)
+        : m_vm(vm)
+        WEBCORE_FOREACH_PROCESSOBJECT_BUILTIN_FUNCTION_NAME(INITIALIZE_BUILTIN_NAMES)
+#define INITIALIZE_BUILTIN_SOURCE_MEMBERS(name, functionName, overriddenName, length) , m_##name##Source(JSC::makeSource(StringImpl::createWithoutCopying(s_##name, length), { }))
+        WEBCORE_FOREACH_PROCESSOBJECT_BUILTIN_CODE(INITIALIZE_BUILTIN_SOURCE_MEMBERS)
+#undef INITIALIZE_BUILTIN_SOURCE_MEMBERS
+    {
+    }
+
+#define EXPOSE_BUILTIN_EXECUTABLES(name, functionName, overriddenName, length) \
+    JSC::UnlinkedFunctionExecutable* name##Executable(); \
+    const JSC::SourceCode& name##Source() const { return m_##name##Source; }
+    WEBCORE_FOREACH_PROCESSOBJECT_BUILTIN_CODE(EXPOSE_BUILTIN_EXECUTABLES)
+#undef EXPOSE_BUILTIN_EXECUTABLES
+
+    WEBCORE_FOREACH_PROCESSOBJECT_BUILTIN_FUNCTION_NAME(DECLARE_BUILTIN_IDENTIFIER_ACCESSOR)
+
+    void exportNames();
+
+private:
+    JSC::VM& m_vm;
+
+    WEBCORE_FOREACH_PROCESSOBJECT_BUILTIN_FUNCTION_NAME(DECLARE_BUILTIN_NAMES)
+
+#define DECLARE_BUILTIN_SOURCE_MEMBERS(name, functionName, overriddenName, length) \
+    JSC::SourceCode m_##name##Source;\
+    JSC::Weak<JSC::UnlinkedFunctionExecutable> m_##name##Executable;
+    WEBCORE_FOREACH_PROCESSOBJECT_BUILTIN_CODE(DECLARE_BUILTIN_SOURCE_MEMBERS)
+#undef DECLARE_BUILTIN_SOURCE_MEMBERS
+
+};
+
+#define DEFINE_BUILTIN_EXECUTABLES(name, functionName, overriddenName, length) \
+inline JSC::UnlinkedFunctionExecutable* ProcessObjectBuiltinsWrapper::name##Executable() \
+{\
+    if (!m_##name##Executable) {\
+        JSC::Identifier executableName = functionName##PublicName();\
+        if (overriddenName)\
+            executableName = JSC::Identifier::fromString(m_vm, overriddenName);\
+        m_##name##Executable = JSC::Weak<JSC::UnlinkedFunctionExecutable>(JSC::createBuiltinExecutable(m_vm, m_##name##Source, executableName, s_##name##ImplementationVisibility, s_##name##ConstructorKind, s_##name##ConstructAbility), this, &m_##name##Executable);\
+    }\
+    return m_##name##Executable.get();\
+}
+WEBCORE_FOREACH_PROCESSOBJECT_BUILTIN_CODE(DEFINE_BUILTIN_EXECUTABLES)
+#undef DEFINE_BUILTIN_EXECUTABLES
+
+inline void ProcessObjectBuiltinsWrapper::exportNames()
+{
+#define EXPORT_FUNCTION_NAME(name) m_vm.propertyNames->appendExternalName(name##PublicName(), name##PrivateName());
+    WEBCORE_FOREACH_PROCESSOBJECT_BUILTIN_FUNCTION_NAME(EXPORT_FUNCTION_NAME)
+#undef EXPORT_FUNCTION_NAME
+}
+
+} // namespace WebCore
diff --git a/src/bun.js/builtins/cpp/ReadableStreamBuiltins.cpp b/src/bun.js/builtins/cpp/ReadableStreamBuiltins.cpp
index 830fbfd51..03dcd26cb 100644
--- a/src/bun.js/builtins/cpp/ReadableStreamBuiltins.cpp
+++ b/src/bun.js/builtins/cpp/ReadableStreamBuiltins.cpp
@@ -211,6 +211,106 @@ const char* const s_readableStreamReadableStreamToBlobCode =
     "})\n" \
 ;
 
+const JSC::ConstructAbility s_readableStreamReadableStreamToNodeReadableCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
+const JSC::ConstructorKind s_readableStreamReadableStreamToNodeReadableCodeConstructorKind = JSC::ConstructorKind::None;
+const JSC::ImplementationVisibility s_readableStreamReadableStreamToNodeReadableCodeImplementationVisibility = JSC::ImplementationVisibility::Private;
+const int s_readableStreamReadableStreamToNodeReadableCodeLength = 2476;
+static const JSC::Intrinsic s_readableStreamReadableStreamToNodeReadableCodeIntrinsic = JSC::NoIntrinsic;
+const char* const s_readableStreamReadableStreamToNodeReadableCode =
+    "(function (stream) {\n" \
+    "    \"use strict\";\n" \
+    "    var {Readable} = @require(\"node:stream\");\n" \
+    "\n" \
+    "   var Prototype = class ReadableNodeStream extends Readable {\n" \
+    "        #reader;\n" \
+    "        #stream;\n" \
+    "        #pushed;\n" \
+    "        #boundOnData;\n" \
+    "        #scheduledRead;\n" \
+    "        constructor(stream) {\n" \
+    "            super();\n" \
+    "            this.#stream = stream;\n" \
+    "            this.#reader = @undefined;\n" \
+    "            this.#pushed = [];\n" \
+    "            this.#boundOnData = (result) => this.#onData(result);\n" \
+    "            this.#scheduledRead = false;\n" \
+    "        }\n" \
+    "\n" \
+    "        _read(size = 0) {\n" \
+    "            if (!this.#reader) {\n" \
+    "                this.#reader = this.#stream.getReader();\n" \
+    "            }\n" \
+    "\n" \
+    "            const pushed = this.#pushed;\n" \
+    "            const pending = pushed.length;\n" \
+    "            for (let i = 0; i < pending; i++) {\n" \
+    "                if (!this.push(pushed[i])) {\n" \
+    "                    pushed.splice(0, i);\n" \
+    "                    return;\n" \
+    "                }\n" \
+    "            }\n" \
+    "\n" \
+    "            this.#scheduleRead();\n" \
+    "        }\n" \
+    "\n" \
+    "        #handleData(value) {\n" \
+    "            var i = 0;\n" \
+    "            const expectedCount = this.#pushed.length;\n" \
+    "            var pushed = this.#pushed;\n" \
+    "            try {\n" \
+    "                for (i; i < expectedCount; i++) {\n" \
+    "                    var item = pushed[i];\n" \
+    "                    if (!this.push(item)) {\n" \
+    "                        return false;\n" \
+    "                    }\n" \
+    "                }\n" \
+    "            } catch(e) {\n" \
+    "                this.error(e);\n" \
+    "                return false;\n" \
+    "            } finally {\n" \
+    "                this.#pushed.splice(0, i);\n" \
+    "                if (this.#pushed.length > 0) {\n" \
+    "                    this.#pushed.push(...value);\n" \
+    "                    return false;\n" \
+    "                }\n" \
+    "\n" \
+    "            }\n" \
+    "\n" \
+    "            const valueLength = value.length;\n" \
+    "            for (i = 0; i < valueLength; i++) {\n" \
+    "                if (!this.push(value[i])) {\n" \
+    "                    this.#pushed.push(...value.slice(i));\n" \
+    "                    return false;\n" \
+    "                }\n" \
+    "            }\n" \
+    "\n" \
+    "            return true;\n" \
+    "        }\n" \
+    "\n" \
+    "        #onData({done, value}) {\n" \
+    "            this.#scheduledRead = false;\n" \
+    "\n" \
+    "            if (done) {\n" \
+    "                this.destroy(@undefined);\n" \
+    "                return;\n" \
+    "            }\n" \
+    "\n" \
+    "            if (!this.#handleData(value)) {\n" \
+    "                return;\n" \
+    "            }\n" \
+    "\n" \
+    "            this.#scheduleRead();\n" \
+    "        }\n" \
+    "\n" \
+    "        #scheduleRead() {\n" \
+    "            if (this.#scheduledRead) return;\n" \
+    "            this.#scheduledRead = true;\n" \
+    "            this.#reader.readMany().@then(this.#onData, this.error);\n" \
+    "        }\n" \
+    "   };\n" \
+    "})\n" \
+;
+
 const JSC::ConstructAbility s_readableStreamConsumeReadableStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
 const JSC::ConstructorKind s_readableStreamConsumeReadableStreamCodeConstructorKind = JSC::ConstructorKind::None;
 const JSC::ImplementationVisibility s_readableStreamConsumeReadableStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Private;
@@ -563,6 +663,40 @@ const char* const s_readableStreamLockedCode =
     "})\n" \
 ;
 
+const JSC::ConstructAbility s_readableStreamValuesCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
+const JSC::ConstructorKind s_readableStreamValuesCodeConstructorKind = JSC::ConstructorKind::None;
+const JSC::ImplementationVisibility s_readableStreamValuesCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
+const int s_readableStreamValuesCodeLength = 249;
+static const JSC::Intrinsic s_readableStreamValuesCodeIntrinsic = JSC::NoIntrinsic;
+const char* const s_readableStreamValuesCode =
+    "(function (options) {\n" \
+    "    \"use strict\";\n" \
+    "    var prototype = this?.constructor?.prototype;\n" \
+    "    if (!prototype) {\n" \
+    "        return @undefined;\n" \
+    "    }\n" \
+    "    @readableStreamDefineLazyIterators(prototype);\n" \
+    "    return prototype.values.@call(this, options);\n" \
+    "})\n" \
+;
+
+const JSC::ConstructAbility s_readableStreamLazyAsyncIteratorCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
+const JSC::ConstructorKind s_readableStreamLazyAsyncIteratorCodeConstructorKind = JSC::ConstructorKind::None;
+const JSC::ImplementationVisibility s_readableStreamLazyAsyncIteratorCodeImplementationVisibility = JSC::ImplementationVisibility::Private;
+const int s_readableStreamLazyAsyncIteratorCodeLength = 259;
+static const JSC::Intrinsic s_readableStreamLazyAsyncIteratorCodeIntrinsic = JSC::NoIntrinsic;
+const char* const s_readableStreamLazyAsyncIteratorCode =
+    "(function () {\n" \
+    "    \"use strict\";\n" \
+    "    var prototype = this?.constructor?.prototype;\n" \
+    "    if (!prototype) {\n" \
+    "        return @undefined;\n" \
+    "    }\n" \
+    "    @readableStreamDefineLazyIterators(prototype);\n" \
+    "    return prototype[globalThis.Symbol.asyncIterator].@call(this);\n" \
+    "})\n" \
+;
+
 
 #define DEFINE_BUILTIN_GENERATOR(codeName, functionName, overriddenName, argumentCount) \
 JSC::FunctionExecutable* codeName##Generator(JSC::VM& vm) \
diff --git a/src/bun.js/builtins/cpp/ReadableStreamBuiltins.h b/src/bun.js/builtins/cpp/ReadableStreamBuiltins.h
index 4a7935e83..503cdfd97 100644
--- a/src/bun.js/builtins/cpp/ReadableStreamBuiltins.h
+++ b/src/bun.js/builtins/cpp/ReadableStreamBuiltins.h
@@ -77,6 +77,11 @@ extern const int s_readableStreamReadableStreamToBlobCodeLength;
 extern const JSC::ConstructAbility s_readableStreamReadableStreamToBlobCodeConstructAbility;
 extern const JSC::ConstructorKind s_readableStreamReadableStreamToBlobCodeConstructorKind;
 extern const JSC::ImplementationVisibility s_readableStreamReadableStreamToBlobCodeImplementationVisibility;
+extern const char* const s_readableStreamReadableStreamToNodeReadableCode;
+extern const int s_readableStreamReadableStreamToNodeReadableCodeLength;
+extern const JSC::ConstructAbility s_readableStreamReadableStreamToNodeReadableCodeConstructAbility;
+extern const JSC::ConstructorKind s_readableStreamReadableStreamToNodeReadableCodeConstructorKind;
+extern const JSC::ImplementationVisibility s_readableStreamReadableStreamToNodeReadableCodeImplementationVisibility;
 extern const char* const s_readableStreamConsumeReadableStreamCode;
 extern const int s_readableStreamConsumeReadableStreamCodeLength;
 extern const JSC::ConstructAbility s_readableStreamConsumeReadableStreamCodeConstructAbility;
@@ -122,6 +127,16 @@ extern const int s_readableStreamLockedCodeLength;
 extern const JSC::ConstructAbility s_readableStreamLockedCodeConstructAbility;
 extern const JSC::ConstructorKind s_readableStreamLockedCodeConstructorKind;
 extern const JSC::ImplementationVisibility s_readableStreamLockedCodeImplementationVisibility;
+extern const char* const s_readableStreamValuesCode;
+extern const int s_readableStreamValuesCodeLength;
+extern const JSC::ConstructAbility s_readableStreamValuesCodeConstructAbility;
+extern const JSC::ConstructorKind s_readableStreamValuesCodeConstructorKind;
+extern const JSC::ImplementationVisibility s_readableStreamValuesCodeImplementationVisibility;
+extern const char* const s_readableStreamLazyAsyncIteratorCode;
+extern const int s_readableStreamLazyAsyncIteratorCodeLength;
+extern const JSC::ConstructAbility s_readableStreamLazyAsyncIteratorCodeConstructAbility;
+extern const JSC::ConstructorKind s_readableStreamLazyAsyncIteratorCodeConstructorKind;
+extern const JSC::ImplementationVisibility s_readableStreamLazyAsyncIteratorCodeImplementationVisibility;
 
 #define WEBCORE_FOREACH_READABLESTREAM_BUILTIN_DATA(macro) \
     macro(initializeReadableStream, readableStreamInitializeReadableStream, 2) \
@@ -130,6 +145,7 @@ extern const JSC::ImplementationVisibility s_readableStreamLockedCodeImplementat
     macro(readableStreamToArrayBuffer, readableStreamReadableStreamToArrayBuffer, 1) \
     macro(readableStreamToJSON, readableStreamReadableStreamToJSON, 1) \
     macro(readableStreamToBlob, readableStreamReadableStreamToBlob, 1) \
+    macro(readableStreamToNodeReadable, readableStreamReadableStreamToNodeReadable, 1) \
     macro(consumeReadableStream, readableStreamConsumeReadableStream, 3) \
     macro(createEmptyReadableStream, readableStreamCreateEmptyReadableStream, 0) \
     macro(createNativeReadableStream, readableStreamCreateNativeReadableStream, 3) \
@@ -139,6 +155,8 @@ extern const JSC::ImplementationVisibility s_readableStreamLockedCodeImplementat
     macro(pipeTo, readableStreamPipeTo, 1) \
     macro(tee, readableStreamTee, 0) \
     macro(locked, readableStreamLocked, 0) \
+    macro(values, readableStreamValues, 1) \
+    macro(lazyAsyncIterator, readableStreamLazyAsyncIterator, 0) \
 
 #define WEBCORE_BUILTIN_READABLESTREAM_INITIALIZEREADABLESTREAM 1
 #define WEBCORE_BUILTIN_READABLESTREAM_READABLESTREAMTOARRAY 1
@@ -146,6 +164,7 @@ extern const JSC::ImplementationVisibility s_readableStreamLockedCodeImplementat
 #define WEBCORE_BUILTIN_READABLESTREAM_READABLESTREAMTOARRAYBUFFER 1
 #define WEBCORE_BUILTIN_READABLESTREAM_READABLESTREAMTOJSON 1
 #define WEBCORE_BUILTIN_READABLESTREAM_READABLESTREAMTOBLOB 1
+#define WEBCORE_BUILTIN_READABLESTREAM_READABLESTREAMTONODEREADABLE 1
 #define WEBCORE_BUILTIN_READABLESTREAM_CONSUMEREADABLESTREAM 1
 #define WEBCORE_BUILTIN_READABLESTREAM_CREATEEMPTYREADABLESTREAM 1
 #define WEBCORE_BUILTIN_READABLESTREAM_CREATENATIVEREADABLESTREAM 1
@@ -155,6 +174,8 @@ extern const JSC::ImplementationVisibility s_readableStreamLockedCodeImplementat
 #define WEBCORE_BUILTIN_READABLESTREAM_PIPETO 1
 #define WEBCORE_BUILTIN_READABLESTREAM_TEE 1
 #define WEBCORE_BUILTIN_READABLESTREAM_LOCKED 1
+#define WEBCORE_BUILTIN_READABLESTREAM_VALUES 1
+#define WEBCORE_BUILTIN_READABLESTREAM_LAZYASYNCITERATOR 1
 
 #define WEBCORE_FOREACH_READABLESTREAM_BUILTIN_CODE(macro) \
     macro(readableStreamInitializeReadableStreamCode, initializeReadableStream, ASCIILiteral(), s_readableStreamInitializeReadableStreamCodeLength) \
@@ -163,6 +184,7 @@ extern const JSC::ImplementationVisibility s_readableStreamLockedCodeImplementat
     macro(readableStreamReadableStreamToArrayBufferCode, readableStreamToArrayBuffer, ASCIILiteral(), s_readableStreamReadableStreamToArrayBufferCodeLength) \
     macro(readableStreamReadableStreamToJSONCode, readableStreamToJSON, ASCIILiteral(), s_readableStreamReadableStreamToJSONCodeLength) \
     macro(readableStreamReadableStreamToBlobCode, readableStreamToBlob, ASCIILiteral(), s_readableStreamReadableStreamToBlobCodeLength) \
+    macro(readableStreamReadableStreamToNodeReadableCode, readableStreamToNodeReadable, ASCIILiteral(), s_readableStreamReadableStreamToNodeReadableCodeLength) \
     macro(readableStreamConsumeReadableStreamCode, consumeReadableStream, ASCIILiteral(), s_readableStreamConsumeReadableStreamCodeLength) \
     macro(readableStreamCreateEmptyReadableStreamCode, createEmptyReadableStream, ASCIILiteral(), s_readableStreamCreateEmptyReadableStreamCodeLength) \
     macro(readableStreamCreateNativeReadableStreamCode, createNativeReadableStream, ASCIILiteral(), s_readableStreamCreateNativeReadableStreamCodeLength) \
@@ -172,6 +194,8 @@ extern const JSC::ImplementationVisibility s_readableStreamLockedCodeImplementat
     macro(readableStreamPipeToCode, pipeTo, ASCIILiteral(), s_readableStreamPipeToCodeLength) \
     macro(readableStreamTeeCode, tee, ASCIILiteral(), s_readableStreamTeeCodeLength) \
     macro(readableStreamLockedCode, locked, "get locked"_s, s_readableStreamLockedCodeLength) \
+    macro(readableStreamValuesCode, values, ASCIILiteral(), s_readableStreamValuesCodeLength) \
+    macro(readableStreamLazyAsyncIteratorCode, lazyAsyncIterator, ASCIILiteral(), s_readableStreamLazyAsyncIteratorCodeLength) \
 
 #define WEBCORE_FOREACH_READABLESTREAM_BUILTIN_FUNCTION_NAME(macro) \
     macro(cancel) \
@@ -180,6 +204,7 @@ extern const JSC::ImplementationVisibility s_readableStreamLockedCodeImplementat
     macro(createNativeReadableStream) \
     macro(getReader) \
     macro(initializeReadableStream) \
+    macro(lazyAsyncIterator) \
     macro(locked) \
     macro(pipeThrough) \
     macro(pipeTo) \
@@ -187,8 +212,10 @@ extern const JSC::ImplementationVisibility s_readableStreamLockedCodeImplementat
     macro(readableStreamToArrayBuffer) \
     macro(readableStreamToBlob) \
     macro(readableStreamToJSON) \
+    macro(readableStreamToNodeReadable) \
     macro(readableStreamToText) \
     macro(tee) \
+    macro(values) \
 
 #define DECLARE_BUILTIN_GENERATOR(codeName, functionName, overriddenName, argumentCount) \
     JSC::FunctionExecutable* codeName##Generator(JSC::VM&);
diff --git a/src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp b/src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp
index 436de27e0..b1914d83d 100644
--- a/src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp
+++ b/src/bun.js/builtins/cpp/ReadableStreamDefaultReaderBuiltins.cpp
@@ -93,7 +93,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 = 3712;
+const int s_readableStreamDefaultReaderReadManyCodeLength = 4130;
 static const JSC::Intrinsic s_readableStreamDefaultReaderReadManyCodeIntrinsic = JSC::NoIntrinsic;
 const char* const s_readableStreamDefaultReaderReadManyCode =
     "(function ()\n" \
@@ -117,25 +117,34 @@ const char* const s_readableStreamDefaultReaderReadManyCode =
     "\n" \
     "    \n" \
     "    var controller = @getByIdDirectPrivate(stream, \"readableStreamController\");\n" \
+    "    var queue  = @getByIdDirectPrivate(controller, \"queue\");\n" \
+    "    \n" \
+    "    if (!queue) {\n" \
+    "        return controller.@pull(\n" \
+    "            controller\n" \
+    "        ).@then(\n" \
+    "            ({done, value}) => (done ? { done: true, value: [], size: 0 } : { value: [value], size: 1, done: false }));\n" \
+    "    }\n" \
     "\n" \
-    "    const content = @getByIdDirectPrivate(controller, \"queue\").content;\n" \
-    "    var size = @getByIdDirectPrivate(controller, \"queue\").size;\n" \
+    "    const content = queue.content;\n" \
+    "    var size = queue.size;\n" \
     "    var values = content.toArray(false);\n" \
+    "    \n" \
     "    var length = values.length;\n" \
     "\n" \
     "    if (length > 0) {\n" \
-    "\n" \
+    "        var outValues = @newArrayWithSize(length);\n" \
     "        if (@isReadableByteStreamController(controller)) {\n" \
-    "            for (var i = 0; i < value.length; i++) {\n" \
-    "                const buf = value[i];\n" \
+    "            for (var i = 0; i < length; i++) {\n" \
+    "                const buf = values[i];\n" \
     "                if (!(@ArrayBuffer.@isView(buf) || buf instanceof @ArrayBuffer)) {\n" \
-    "                    value[i] = new @Uint8Array(buf.buffer, buf.byteOffset, buf.byteLength);\n" \
+    "                    @putByValDirect(outValues, i, @Uint8Array(buf.buffer, buf.byteOffset, buf.byteLength));\n" \
     "                }\n" \
     "            }\n" \
     "        } else {\n" \
-    "            values[0] = values[0].value;\n" \
-    "            for (var i = 1; i < values.length; i++) {\n" \
-    "                values[i] = values[i].value;\n" \
+    "            @putByValDirect(outValues, 0, values[0].value);\n" \
+    "            for (var i = 1; i < length; i++) {\n" \
+    "                @putByValDirect(outValues, i, values[i].value);\n" \
     "            }\n" \
     "        }\n" \
     "        \n" \
@@ -148,7 +157,7 @@ const char* const s_readableStreamDefaultReaderReadManyCode =
     "        else if (@isReadableByteStreamController(controller))\n" \
     "            @readableByteStreamControllerCallPullIfNeeded(controller);\n" \
     "\n" \
-    "        return {value: values, size, done: false};\n" \
+    "        return {value: outValues, size, done: false};\n" \
     "    }\n" \
     "\n" \
     "    var onPullMany = (result) => {\n" \
@@ -159,17 +168,19 @@ const char* const s_readableStreamDefaultReaderReadManyCode =
     "        \n" \
     "        var queue = @getByIdDirectPrivate(controller, \"queue\");\n" \
     "        var value = [result.value].concat(queue.content.toArray(false));\n" \
+    "        var length = value.length;\n" \
     "\n" \
     "        if (@isReadableByteStreamController(controller)) {\n" \
-    "            for (var i = 0; i < value.length; i++) {\n" \
+    "            for (var i = 0; i < length; i++) {\n" \
     "                const buf = value[i];\n" \
     "                if (!(@ArrayBuffer.@isView(buf) || buf instanceof @ArrayBuffer)) {\n" \
-    "                    value[i] = new @Uint8Array(buf.buffer, buf.byteOffset, buf.byteLength);\n" \
+    "                    const {buffer, byteOffset, byteLength} = buf;\n" \
+    "                    @putByValDirect(value, i, new @Uint8Array(buffer, byteOffset, byteLength));\n" \
     "                }\n" \
     "            }\n" \
     "        } else {\n" \
-    "            for (var i = 1; i < value.length; i++) {\n" \
-    "                value[i] = value[i].value;\n" \
+    "            for (var i = 1; i < length; i++) {\n" \
+    "                @putByValDirect(value, i, value[i].value);\n" \
     "            }\n" \
     "        }\n" \
     "        \n" \
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) \
diff --git a/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.h b/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.h
index 335637c81..a617260be 100644
--- a/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.h
+++ b/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.h
@@ -362,6 +362,11 @@ extern const int s_readableStreamInternalsReadableStreamToArrayDirectCodeLength;
 extern const JSC::ConstructAbility s_readableStreamInternalsReadableStreamToArrayDirectCodeConstructAbility;
 extern const JSC::ConstructorKind s_readableStreamInternalsReadableStreamToArrayDirectCodeConstructorKind;
 extern const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamToArrayDirectCodeImplementationVisibility;
+extern const char* const s_readableStreamInternalsReadableStreamDefineLazyIteratorsCode;
+extern const int s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeLength;
+extern const JSC::ConstructAbility s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeConstructAbility;
+extern const JSC::ConstructorKind s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeConstructorKind;
+extern const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeImplementationVisibility;
 
 #define WEBCORE_FOREACH_READABLESTREAMINTERNALS_BUILTIN_DATA(macro) \
     macro(readableStreamReaderGenericInitialize, readableStreamInternalsReadableStreamReaderGenericInitialize, 2) \
@@ -427,6 +432,7 @@ extern const JSC::ImplementationVisibility s_readableStreamInternalsReadableStre
     macro(readableStreamToArrayBufferDirect, readableStreamInternalsReadableStreamToArrayBufferDirect, 2) \
     macro(readableStreamToTextDirect, readableStreamInternalsReadableStreamToTextDirect, 2) \
     macro(readableStreamToArrayDirect, readableStreamInternalsReadableStreamToArrayDirect, 2) \
+    macro(readableStreamDefineLazyIterators, readableStreamInternalsReadableStreamDefineLazyIterators, 1) \
 
 #define WEBCORE_BUILTIN_READABLESTREAMINTERNALS_READABLESTREAMREADERGENERICINITIALIZE 1
 #define WEBCORE_BUILTIN_READABLESTREAMINTERNALS_PRIVATEINITIALIZEREADABLESTREAMDEFAULTCONTROLLER 1
@@ -491,6 +497,7 @@ extern const JSC::ImplementationVisibility s_readableStreamInternalsReadableStre
 #define WEBCORE_BUILTIN_READABLESTREAMINTERNALS_READABLESTREAMTOARRAYBUFFERDIRECT 1
 #define WEBCORE_BUILTIN_READABLESTREAMINTERNALS_READABLESTREAMTOTEXTDIRECT 1
 #define WEBCORE_BUILTIN_READABLESTREAMINTERNALS_READABLESTREAMTOARRAYDIRECT 1
+#define WEBCORE_BUILTIN_READABLESTREAMINTERNALS_READABLESTREAMDEFINELAZYITERATORS 1
 
 #define WEBCORE_FOREACH_READABLESTREAMINTERNALS_BUILTIN_CODE(macro) \
     macro(readableStreamInternalsReadableStreamReaderGenericInitializeCode, readableStreamReaderGenericInitialize, ASCIILiteral(), s_readableStreamInternalsReadableStreamReaderGenericInitializeCodeLength) \
@@ -556,6 +563,7 @@ extern const JSC::ImplementationVisibility s_readableStreamInternalsReadableStre
     macro(readableStreamInternalsReadableStreamToArrayBufferDirectCode, readableStreamToArrayBufferDirect, ASCIILiteral(), s_readableStreamInternalsReadableStreamToArrayBufferDirectCodeLength) \
     macro(readableStreamInternalsReadableStreamToTextDirectCode, readableStreamToTextDirect, ASCIILiteral(), s_readableStreamInternalsReadableStreamToTextDirectCodeLength) \
     macro(readableStreamInternalsReadableStreamToArrayDirectCode, readableStreamToArrayDirect, ASCIILiteral(), s_readableStreamInternalsReadableStreamToArrayDirectCodeLength) \
+    macro(readableStreamInternalsReadableStreamDefineLazyIteratorsCode, readableStreamDefineLazyIterators, ASCIILiteral(), s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeLength) \
 
 #define WEBCORE_FOREACH_READABLESTREAMINTERNALS_BUILTIN_FUNCTION_NAME(macro) \
     macro(acquireReadableStreamDefaultReader) \
@@ -604,6 +612,7 @@ extern const JSC::ImplementationVisibility s_readableStreamInternalsReadableStre
     macro(readableStreamDefaultControllerShouldCallPull) \
     macro(readableStreamDefaultControllerStart) \
     macro(readableStreamDefaultReaderRead) \
+    macro(readableStreamDefineLazyIterators) \
     macro(readableStreamError) \
     macro(readableStreamFulfillReadRequest) \
     macro(readableStreamIntoArray) \
diff --git a/src/bun.js/builtins/cpp/WebCoreJSBuiltins.h b/src/bun.js/builtins/cpp/WebCoreJSBuiltins.h
index 2e8d8a578..12e9719d3 100644
--- a/src/bun.js/builtins/cpp/WebCoreJSBuiltins.h
+++ b/src/bun.js/builtins/cpp/WebCoreJSBuiltins.h
@@ -40,6 +40,7 @@
 #include "ImportMetaObjectBuiltins.h"
 #include "JSBufferConstructorBuiltins.h"
 #include "JSBufferPrototypeBuiltins.h"
+#include "ProcessObjectBuiltins.h"
 #include "ReadableByteStreamControllerBuiltins.h"
 #include "ReadableByteStreamInternalsBuiltins.h"
 #include "ReadableStreamBYOBReaderBuiltins.h"
@@ -68,6 +69,7 @@ public:
         , m_importMetaObjectBuiltins(m_vm)
         , m_jsBufferConstructorBuiltins(m_vm)
         , m_jsBufferPrototypeBuiltins(m_vm)
+        , m_processObjectBuiltins(m_vm)
         , m_readableByteStreamControllerBuiltins(m_vm)
         , m_readableByteStreamInternalsBuiltins(m_vm)
         , m_readableStreamBuiltins(m_vm)
@@ -96,6 +98,7 @@ public:
     ImportMetaObjectBuiltinsWrapper& importMetaObjectBuiltins() { return m_importMetaObjectBuiltins; }
     JSBufferConstructorBuiltinsWrapper& jsBufferConstructorBuiltins() { return m_jsBufferConstructorBuiltins; }
     JSBufferPrototypeBuiltinsWrapper& jsBufferPrototypeBuiltins() { return m_jsBufferPrototypeBuiltins; }
+    ProcessObjectBuiltinsWrapper& processObjectBuiltins() { return m_processObjectBuiltins; }
     ReadableByteStreamControllerBuiltinsWrapper& readableByteStreamControllerBuiltins() { return m_readableByteStreamControllerBuiltins; }
     ReadableByteStreamInternalsBuiltinsWrapper& readableByteStreamInternalsBuiltins() { return m_readableByteStreamInternalsBuiltins; }
     ReadableStreamBuiltinsWrapper& readableStreamBuiltins() { return m_readableStreamBuiltins; }
@@ -119,6 +122,7 @@ private:
     ImportMetaObjectBuiltinsWrapper m_importMetaObjectBuiltins;
     JSBufferConstructorBuiltinsWrapper m_jsBufferConstructorBuiltins;
     JSBufferPrototypeBuiltinsWrapper m_jsBufferPrototypeBuiltins;
+    ProcessObjectBuiltinsWrapper m_processObjectBuiltins;
     ReadableByteStreamControllerBuiltinsWrapper m_readableByteStreamControllerBuiltins;
     ReadableByteStreamInternalsBuiltinsWrapper m_readableByteStreamInternalsBuiltins;
     ReadableStreamBuiltinsWrapper m_readableStreamBuiltins;