direct streams mostly workjarred/direct

1 files changed, 146 insertions, 177 deletions

diff --git a/src/javascript/jsc/bindings/JSSink.h b/src/javascript/jsc/bindings/JSSink.h
index a9085cbf4..cc4f667e0 100644
--- a/src/javascript/jsc/bindings/JSSink.h
+++ b/src/javascript/jsc/bindings/JSSink.h
@@ -1,6 +1,6 @@
 
 // AUTO-GENERATED FILE. DO NOT EDIT.
-// Generated by /Users/jarred/Code/bun/src/javascript/jsc/generate-JSSink.js at 2022-06-14T08:19:26.543Z
+// Generated by /Users/jarred/Code/bun/src/javascript/jsc/generate-jssink.js at 2022-06-15T10:28:21.209Z
 //
 #pragma once
 
@@ -15,184 +15,153 @@ extern "C" bool JSSink_isSink(JSC::JSGlobalObject*, JSC::EncodedJSValue);
 
 namespace WebCore {
 using namespace JSC;
-class JSArrayBufferSinkConstructor final : public JSC::InternalFunction {
-public:
-    using Base = JSC::InternalFunction;
-    static JSArrayBufferSinkConstructor* create(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::Structure* structure, JSC::JSObject* prototype);
-    static constexpr SinkID Sink = SinkID::ArrayBufferSink;
-
-    static constexpr unsigned StructureFlags = Base::StructureFlags;
-    static constexpr bool needsDestruction = false;
-
-    DECLARE_EXPORT_INFO;
-    template<typename, JSC::SubspaceAccess mode> static JSC::GCClient::IsoSubspace* subspaceFor(JSC::VM& vm)
-    {
-        if constexpr (mode == JSC::SubspaceAccess::Concurrently)
-            return nullptr;
-        return WebCore::subspaceForImpl<JSArrayBufferSinkConstructor, WebCore::UseCustomHeapCellType::No>(
-            vm,
-            [](auto& spaces) { return spaces.m_clientSubspaceForJSSinkConstructor.get(); },
-            [](auto& spaces, auto&& space) { spaces.m_clientSubspaceForJSSinkConstructor = WTFMove(space); },
-            [](auto& spaces) { return spaces.m_subspaceForJSSinkConstructor.get(); },
-            [](auto& spaces, auto&& space) { spaces.m_subspaceForJSSinkConstructor = WTFMove(space); });
-    }
-
-    static JSC::Structure* createStructure(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::JSValue prototype)
-    {
-        return JSC::Structure::create(vm, globalObject, prototype, JSC::TypeInfo(JSC::InternalFunctionType, StructureFlags), info());
-    }
-    void initializeProperties(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::JSObject* prototype);
-
-    // Must be defined for each specialization class.
-    static JSC::EncodedJSValue JSC_HOST_CALL_ATTRIBUTES construct(JSC::JSGlobalObject*, JSC::CallFrame*);
-
-private:
-    JSArrayBufferSinkConstructor(JSC::VM& vm, JSC::Structure* structure, JSC::NativeFunction nativeFunction)
-        : Base(vm, structure, nativeFunction, nativeFunction)
-
-    {
-    }
-
-    void finishCreation(JSC::VM&, JSC::JSGlobalObject* globalObject, JSC::JSObject* prototype);
-};
-
-class JSReadableArrayBufferSinkControllerConstructor final : public JSC::InternalFunction {
-public:
-    using Base = JSC::InternalFunction;
-    static JSReadableArrayBufferSinkControllerConstructor* create(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::Structure* structure, JSC::JSObject* prototype);
-    static constexpr SinkID Sink = SinkID::ArrayBufferSink;
-
-    static constexpr unsigned StructureFlags = Base::StructureFlags;
-    static constexpr bool needsDestruction = false;
-
-    DECLARE_EXPORT_INFO;
-    template<typename, JSC::SubspaceAccess mode> static JSC::GCClient::IsoSubspace* subspaceFor(JSC::VM& vm)
-    {
-        if constexpr (mode == JSC::SubspaceAccess::Concurrently)
-            return nullptr;
-        return WebCore::subspaceForImpl<JSReadableArrayBufferSinkControllerConstructor, WebCore::UseCustomHeapCellType::No>(
-            vm,
-            [](auto& spaces) { return spaces.m_clientSubspaceForJSSinkConstructor.get(); },
-            [](auto& spaces, auto&& space) { spaces.m_clientSubspaceForJSSinkConstructor = WTFMove(space); },
-            [](auto& spaces) { return spaces.m_subspaceForJSSinkConstructor.get(); },
-            [](auto& spaces, auto&& space) { spaces.m_subspaceForJSSinkConstructor = WTFMove(space); });
-    }
-
-    static JSC::Structure* createStructure(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::JSValue prototype)
-    {
-        return JSC::Structure::create(vm, globalObject, prototype, JSC::TypeInfo(JSC::InternalFunctionType, StructureFlags), info());
-    }
-    void initializeProperties(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::JSObject* prototype);
-
-    // Must be defined for each specialization class.
-    static JSC::EncodedJSValue JSC_HOST_CALL_ATTRIBUTES construct(JSC::JSGlobalObject*, JSC::CallFrame*);
-
-private:
-    JSReadableArrayBufferSinkControllerConstructor(JSC::VM& vm, JSC::Structure* structure, JSC::NativeFunction nativeFunction)
-        : Base(vm, structure, nativeFunction, nativeFunction)
-
-    {
-    }
-
-    void finishCreation(JSC::VM&, JSC::JSGlobalObject* globalObject, JSC::JSObject* prototype);
-};
-
-class JSArrayBufferSink final : public JSC::JSDestructibleObject {
-public:
-    using Base = JSC::JSDestructibleObject;
-    static JSArrayBufferSink* create(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::Structure* structure, void* sinkPtr);
-    static constexpr SinkID Sink = SinkID::ArrayBufferSink;
-
-    DECLARE_EXPORT_INFO;
-    template<typename, JSC::SubspaceAccess mode> static JSC::GCClient::IsoSubspace* subspaceFor(JSC::VM& vm)
-    {
-        if constexpr (mode == JSC::SubspaceAccess::Concurrently)
-            return nullptr;
-        return WebCore::subspaceForImpl<JSArrayBufferSink, WebCore::UseCustomHeapCellType::No>(
-            vm,
-            [](auto& spaces) { return spaces.m_clientSubspaceForJSSink.get(); },
-            [](auto& spaces, auto&& space) { spaces.m_clientSubspaceForJSSink = WTFMove(space); },
-            [](auto& spaces) { return spaces.m_subspaceForJSSink.get(); },
-            [](auto& spaces, auto&& space) { spaces.m_subspaceForJSSink = WTFMove(space); });
-    }
-
-    static void destroy(JSC::JSCell*);
-    static JSC::Structure* createStructure(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::JSValue prototype)
-    {
-        return JSC::Structure::create(vm, globalObject, prototype, JSC::TypeInfo(JSC::ObjectType, StructureFlags), info());
-    }
-
-    ~JSArrayBufferSink();
-
-    void* wrapped() const { return m_sinkPtr; }
-
-    static void analyzeHeap(JSCell*, JSC::HeapAnalyzer&);
-
-    void* m_sinkPtr;
-
-    JSArrayBufferSink(JSC::VM& vm, JSC::Structure* structure, void* sinkPtr)
-        : Base(vm, structure)
-    {
-        m_sinkPtr = sinkPtr;
-    }
-
-    void finishCreation(JSC::VM&);
-};
-
-class JSReadableArrayBufferSinkController final : public JSC::JSDestructibleObject {
-public:
-    using Base = JSC::JSDestructibleObject;
-    static JSReadableArrayBufferSinkController* create(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::Structure* structure, void* sinkPtr, JSC::JSFunction* pullFunction, JSC::JSFunction* cancelFunction);
-    static constexpr SinkID Sink = SinkID::ArrayBufferSink;
-
-    DECLARE_EXPORT_INFO;
-    template<typename, JSC::SubspaceAccess mode> static JSC::GCClient::IsoSubspace* subspaceFor(JSC::VM& vm)
-    {
-        if constexpr (mode == JSC::SubspaceAccess::Concurrently)
-            return nullptr;
-        return WebCore::subspaceForImpl<JSReadableArrayBufferSinkController, WebCore::UseCustomHeapCellType::No>(
-            vm,
-            [](auto& spaces) { return spaces.m_clientSubspaceForJSSinkController.get(); },
-            [](auto& spaces, auto&& space) { spaces.m_clientSubspaceForJSSinkController = WTFMove(space); },
-            [](auto& spaces) { return spaces.m_subspaceForJSSinkController.get(); },
-            [](auto& spaces, auto&& space) { spaces.m_subspaceForJSSinkController = WTFMove(space); });
-    }
-
-    static void destroy(JSC::JSCell*);
-    static JSC::Structure* createStructure(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::JSValue prototype)
-    {
-        return JSC::Structure::create(vm, globalObject, prototype, JSC::TypeInfo(JSC::ObjectType, StructureFlags), info());
-    }
-
-    ~JSReadableArrayBufferSinkController();
-
-    void* wrapped() const { return m_sinkPtr; }
-
-    static void analyzeHeap(JSCell*, JSC::HeapAnalyzer&);
-
-    void* m_sinkPtr;
-    mutable WriteBarrier<JSFunction> m_pull;
-    mutable WriteBarrier<JSFunction> m_cancel;
-    // start is not stored because it doesn't need to be
-
-    DECLARE_VISIT_CHILDREN;
-
-    JSReadableArrayBufferSinkController(JSC::VM& vm, JSC::Structure* structure, void* sinkPtr, JSC::JSFunction* pullFunction, JSC::JSFunction* cancelFunction)
-        : Base(vm, structure)
-    {
-        if (pullFunction != nullptr)
-            m_pull.set(vm, this, pullFunction);
-        if (cancelFunction != nullptr)
-            m_cancel.set(vm, this, cancelFunction);
-
-        m_sinkPtr = sinkPtr;
-    }
-
-    void finishCreation(JSC::VM&);
-};
+
+JSC_DECLARE_HOST_FUNCTION(functionStartDirectStream);
+class JSArrayBufferSinkConstructor final : public JSC::InternalFunction {                                                                                                     
+        public:                                                                                                                                                                     
+            using Base = JSC::InternalFunction;                                                                                                                                     
+            static JSArrayBufferSinkConstructor* create(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::Structure* structure, JSC::JSObject* prototype); 
+            static constexpr SinkID Sink = SinkID::ArrayBufferSink;
+                                                                                                                                                                                    
+            static constexpr unsigned StructureFlags = Base::StructureFlags;                                                                                                        
+            static constexpr bool needsDestruction = false;                                                                                                                         
+                                                                                                                                                                                    
+            DECLARE_EXPORT_INFO;                                                                                                                                                    
+            template<typename, JSC::SubspaceAccess mode> static JSC::GCClient::IsoSubspace* subspaceFor(JSC::VM& vm)                                                                
+            {                                                                                                                                                                       
+                if constexpr (mode == JSC::SubspaceAccess::Concurrently)                                                                                                            
+                    return nullptr;                                                                                                                                                 
+                return WebCore::subspaceForImpl<JSArrayBufferSinkConstructor, WebCore::UseCustomHeapCellType::No>(                                                                    
+                    vm,                                                                                                                                                             
+                    [](auto& spaces) { return spaces.m_clientSubspaceForJSSinkConstructor.get(); },                                                                                 
+                    [](auto& spaces, auto&& space) { spaces.m_clientSubspaceForJSSinkConstructor = WTFMove(space); },                                                               
+                    [](auto& spaces) { return spaces.m_subspaceForJSSinkConstructor.get(); },                                                                                       
+                    [](auto& spaces, auto&& space) { spaces.m_subspaceForJSSinkConstructor = WTFMove(space); });                                                                    
+            }                                                                                                                                                                       
+                                                                                                                                                                                    
+            static JSC::Structure* createStructure(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::JSValue prototype)                                                          
+            {                                                                                                                                                                       
+                return JSC::Structure::create(vm, globalObject, prototype, JSC::TypeInfo(JSC::InternalFunctionType, StructureFlags), info());                                                 
+            }                                                                                                                                                                       
+            void initializeProperties(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::JSObject* prototype);   
+            
+            
+            // Must be defined for each specialization class.
+            static JSC::EncodedJSValue JSC_HOST_CALL_ATTRIBUTES construct(JSC::JSGlobalObject*, JSC::CallFrame*);
+                                                                                                                                                               
+        private:                                                                                                                                                                    
+            JSArrayBufferSinkConstructor(JSC::VM& vm, JSC::Structure* structure, JSC::NativeFunction nativeFunction)                                                                  
+                : Base(vm, structure, nativeFunction, nativeFunction)                                                                                                               
+                                                                                                                                                                                    
+            {                                                                                                                                                                       
+            }                                                                                                                                                                       
+                                                                                                                                                                                    
+            void finishCreation(JSC::VM&, JSC::JSGlobalObject* globalObject, JSC::JSObject* prototype);                                                     
+        };                                                                                                                                                                          
+                                                                                                                                                                                    
+        class JSArrayBufferSink final : public JSC::JSDestructibleObject {                                                                                                              
+        public:                                                                                                                                                                     
+            using Base = JSC::JSDestructibleObject;                                                                                                                                 
+            static JSArrayBufferSink* create(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::Structure* structure, void* sinkPtr);       
+            static constexpr SinkID Sink = SinkID::ArrayBufferSink;                                          
+                                                                                                                                                                                    
+            DECLARE_EXPORT_INFO;                                                                                                                                                    
+            template<typename, JSC::SubspaceAccess mode> static JSC::GCClient::IsoSubspace* subspaceFor(JSC::VM& vm)                                                                
+            {                                                                                                                                                                       
+                if constexpr (mode == JSC::SubspaceAccess::Concurrently)                                                                                                            
+                    return nullptr;                                                                                                                                                 
+                return WebCore::subspaceForImpl<JSArrayBufferSink, WebCore::UseCustomHeapCellType::No>(                                                                                 
+                    vm,                                                                                                                                                             
+                    [](auto& spaces) { return spaces.m_clientSubspaceForJSSink.get(); },                                                                                            
+                    [](auto& spaces, auto&& space) { spaces.m_clientSubspaceForJSSink = WTFMove(space); },                                                                          
+                    [](auto& spaces) { return spaces.m_subspaceForJSSink.get(); },                                                                                                  
+                    [](auto& spaces, auto&& space) { spaces.m_subspaceForJSSink = WTFMove(space); });                                                                               
+            }                                                                                                                                                                       
+                                                                                                                                                                                    
+            static void destroy(JSC::JSCell*);                                                                                                                                      
+            static JSC::Structure* createStructure(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::JSValue prototype)                                                          
+            {                                                                                                                                                                       
+                return JSC::Structure::create(vm, globalObject, prototype, JSC::TypeInfo(JSC::ObjectType, StructureFlags), info());                                                 
+            }                                                                                                                                                                       
+                                                                                                                                                                                    
+            ~JSArrayBufferSink();                                                                                                                                                       
+                                                                                                                                                                                    
+            void* wrapped() const { return m_sinkPtr; }                                                                                                                             
+
+            void detach() {
+                m_sinkPtr = nullptr;
+            }                       
+
+            static void analyzeHeap(JSCell*, JSC::HeapAnalyzer&);                                                                                                                   
+                                                                                                                                                                                    
+            void* m_sinkPtr;
+                                                                                                                                                                                    
+            JSArrayBufferSink(JSC::VM& vm, JSC::Structure* structure, void* sinkPtr)                                                                                                    
+                : Base(vm, structure)                                                                                                                                               
+            {                                                                                                                                                                       
+                m_sinkPtr = sinkPtr;                                                                                                                                                
+            }                                                                                                                                                                       
+                                                                                                                                                                                    
+            void finishCreation(JSC::VM&);                                                                                                                                          
+        };
+
+        class JSReadableArrayBufferSinkController final : public JSC::JSDestructibleObject {                                                                                                              
+            public:                                                                                                                                                                     
+                using Base = JSC::JSDestructibleObject;                                                                                                                                 
+                static JSReadableArrayBufferSinkController* create(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::Structure* structure, void* sinkPtr);       
+                static constexpr SinkID Sink = SinkID::ArrayBufferSink;                                          
+                                                                                                                                                                                        
+                DECLARE_EXPORT_INFO;                                                                                                                                                    
+                template<typename, JSC::SubspaceAccess mode> static JSC::GCClient::IsoSubspace* subspaceFor(JSC::VM& vm)                                                                
+                {                                                                                                                                                                       
+                    if constexpr (mode == JSC::SubspaceAccess::Concurrently)                                                                                                            
+                        return nullptr;                                                                                                                                                 
+                    return WebCore::subspaceForImpl<JSReadableArrayBufferSinkController, WebCore::UseCustomHeapCellType::No>(                                                                                 
+                        vm,                                                                                                                                                             
+                        [](auto& spaces) { return spaces.m_clientSubspaceForJSSinkController.get(); },                                                                                            
+                        [](auto& spaces, auto&& space) { spaces.m_clientSubspaceForJSSinkController = WTFMove(space); },                                                                          
+                        [](auto& spaces) { return spaces.m_subspaceForJSSinkController.get(); },                                                                                                  
+                        [](auto& spaces, auto&& space) { spaces.m_subspaceForJSSinkController = WTFMove(space); });                                                                               
+                }                                                                                                                                                                       
+                                                                                                                                                                                        
+                static void destroy(JSC::JSCell*);                                                                                                                                      
+                static JSC::Structure* createStructure(JSC::VM& vm, JSC::JSGlobalObject* globalObject, JSC::JSValue prototype)                                                          
+                {                                                                                                                                                                       
+                    return JSC::Structure::create(vm, globalObject, prototype, JSC::TypeInfo(JSC::ObjectType, StructureFlags), info());                                                 
+                }                                                                                                                                                                       
+                                                                                                                                                                                        
+                ~JSReadableArrayBufferSinkController();                                                                                                                                                       
+
+
+                void* wrapped() const { return m_sinkPtr; }    
+                void detach() {
+                    m_sinkPtr = nullptr;
+                }
+
+                void start(JSC::JSGlobalObject *globalObject, JSC::JSValue readableStream, JSC::JSFunction *onPull, JSC::JSFunction *onClose);
+                DECLARE_VISIT_CHILDREN;
+                                                                                                                                                                                        
+                static void analyzeHeap(JSCell*, JSC::HeapAnalyzer&);                                                                                                                   
+                                                                                                                                                                                        
+                void* m_sinkPtr;
+                mutable WriteBarrier<JSC::JSFunction> m_onPull;
+                mutable WriteBarrier<JSC::JSFunction> m_onClose;
+                mutable JSC::Weak<JSObject> m_weakReadableStream;
+                                                                                                                                                                                        
+                JSReadableArrayBufferSinkController(JSC::VM& vm, JSC::Structure* structure, void* sinkPtr)                                                                                                    
+                    : Base(vm, structure)                                                                                                                                               
+                {                                                                                                                                                                       
+                    m_sinkPtr = sinkPtr;                                                                                                                                                
+                }                                                                                                                                                                       
+                                                                                                                                                                                        
+                void finishCreation(JSC::VM&);                                                                                                                                          
+            };
 
 JSC_DECLARE_CUSTOM_GETTER(functionArrayBufferSink__getter);
-JSC_DECLARE_CUSTOM_GETTER(functionArrayBufferSinkController__getter);
+
+
+
+        
 
 JSObject* createJSSinkPrototype(JSC::VM& vm, JSC::JSGlobalObject* globalObject, WebCore::SinkID sinkID);
 JSObject* createJSSinkControllerPrototype(JSC::VM& vm, JSC::JSGlobalObject* globalObject, WebCore::SinkID sinkID);