Clear all timeout on destroy and close (nodejs#2535)

Signed-off-by: Matteo Collina <hello@matteocollina.com>
crysmags · Feb 27, 2024 · 9c40c26 · 9c40c26
1 parent 25a26b3
commit 9c40c26
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/lib/agent.js b/lib/agent.js
@@ -110,6 +110,9 @@ class Agent extends DispatcherBase {
   async [kClose] () {
     const closePromises = []
     for (const client of this[kClients].values()) {
+      if (client[kDeleteScheduled]) {
+        clearTimeout(client[kDeleteScheduled])
+      }
       closePromises.push(client.close())
     }
     this[kClients].clear()
@@ -120,6 +123,9 @@ class Agent extends DispatcherBase {
   async [kDestroy] (err) {
     const destroyPromises = []
     for (const client of this[kClients].values()) {
+      if (client[kDeleteScheduled]) {
+        clearTimeout(client[kDeleteScheduled])
+      }
       destroyPromises.push(client.destroy(err))
     }
     this[kClients].clear()