From 1f3ce0d962d7af9ad4aac5a7321ab3cf7e3a09d2 Mon Sep 17 00:00:00 2001
From: cirospaciari <ciro.spaciari@gmail.com>
Date: Fri, 18 Oct 2024 08:45:51 -0700
Subject: [PATCH] test

---
 src/js/node/http2.ts | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/src/js/node/http2.ts b/src/js/node/http2.ts
index dc850666a203b..b0ab1bbe532ee 100644
--- a/src/js/node/http2.ts
+++ b/src/js/node/http2.ts
@@ -1568,7 +1568,6 @@ function markStreamClosed(stream: Http2Stream) {
 
   if ((status & StreamState.Closed) === 0) {
     stream[bunHTTP2StreamStatus] = status | StreamState.Closed;
-
     markWritableDone(stream);
   }
 }
@@ -2325,7 +2324,6 @@ class ServerHttp2Session extends Http2Session {
     ) {
       if (!self || typeof stream !== "object") return;
       const headers = toHeaderObject(rawheaders, sensitiveHeadersValue || []);
-
       const status = stream[bunHTTP2StreamStatus];
       if ((status & StreamState.StreamResponded) !== 0) {
         stream.emit("trailers", headers, flags, rawheaders);
@@ -2411,6 +2409,7 @@ class ServerHttp2Session extends Http2Session {
     if (parser) {
       h2EmitAbortToAllStreams(parser);
       h2Detach(parser);
+      this[bunHTTP2Socket]?.removeAllListeners();
       this[bunHTTP2Parser] = null;
     }
     this.close();
@@ -2625,6 +2624,7 @@ class ServerHttp2Session extends Http2Session {
     if (parser) {
       h2EmitErrorToAllStreams(code || constants.NGHTTP2_NO_ERROR);
       h2Detach(parser);
+      this[bunHTTP2Socket]?.removeAllListeners();
       this[bunHTTP2Parser] = null;
     }
     this[bunHTTP2Socket] = null;
@@ -2857,12 +2857,14 @@ class ClientHttp2Session extends Http2Session {
     if (parser) {
       h2EmitAbortToAllStreams(parser);
       h2Detach(parser);
+      this[bunHTTP2Socket]?.removeAllListeners();
       this[bunHTTP2Parser] = null;
     }
     this.close();
     this[bunHTTP2Socket] = null;
   }
   #onError(error: Error) {
+    this[bunHTTP2Socket]?.removeAllListeners();
     this[bunHTTP2Socket] = null;
     this.destroy(error);
   }
@@ -3085,6 +3087,7 @@ class ClientHttp2Session extends Http2Session {
     if (parser) {
       h2EmitErrorToAllStreams(parser, code || constants.NGHTTP2_NO_ERROR);
       h2Detach(parser);
+      this[bunHTTP2Socket]?.removeAllListeners();
     }
     this[bunHTTP2Parser] = null;
     this[bunHTTP2Socket] = null;