feat(bindgen): add drop for external stream class

Author: vados-cosmonic

crates/js-component-bindgen/src/intrinsics/lift.rs

@@ -1050,6 +1050,7 @@ impl LiftIntrinsic {
                             isWritable: streamEnd.isWritable(),
                             writeFn: (v) => {{ return streamEnd.write(v); }},
                             readFn: () => {{ return streamEnd.read(); }},
+                            dropFn: () => {{ return streamEnd.drop(); }},
                         }});
 
                         return [ stream, ctx ];

crates/js-component-bindgen/src/intrinsics/mod.rs

@@ -1015,8 +1015,9 @@ pub struct RenderIntrinsicsArgs<'a> {
 }
 
 /// Intrinsics that should be rendered as early as possible
-const EARLY_INTRINSICS: [Intrinsic; 31] = [
+const EARLY_INTRINSICS: [Intrinsic; 32] = [
     Intrinsic::PromiseWithResolversPonyfill,
+    Intrinsic::SymbolDispose,
     Intrinsic::DebugLog,
     Intrinsic::GlobalAsyncDeterminism,
     Intrinsic::GlobalComponentMemoryMap,

crates/js-component-bindgen/src/intrinsics/p3/async_stream.rs

@@ -1212,6 +1212,8 @@ impl AsyncStreamIntrinsic {
             Self::ExternalStreamClass => {
                 let debug_log_fn = Intrinsic::DebugLog.name();
                 let external_stream_class_name = self.name();
+                let symbol_dispose = Intrinsic::SymbolDispose.name();
+
                 output.push_str(&format!(
                     r#"
                     class {external_stream_class_name} {{
@@ -1220,6 +1222,7 @@ impl AsyncStreamIntrinsic {
                         #isWritable;
                         #writeFn;
                         #readFn;
+                        #dropFn;
 
                         constructor(args) {{
                             {debug_log_fn}('[{external_stream_class_name}#constructor()] args', args);
@@ -1237,6 +1240,8 @@ impl AsyncStreamIntrinsic {
 
                             if (this.#isReadable && args.readFn === undefined) {{ throw new TypeError("missing read fn"); }}
                             this.#readFn = args.readFn;
+
+                            this.#dropFn = args.dropFn;
                         }}
 
                         globalRep() {{ return this.#globalRep; }}
@@ -1259,6 +1264,11 @@ impl AsyncStreamIntrinsic {
 
                             this.#writeFn(obj);
                         }}
+
+                        [{symbol_dispose}]() {{
+                            this.#dropFn();
+                        }}
+
                     }}
                     "#
                 ));