From 89a0b4ccb26787a801ef39b7cdcb8c30426a6d32 Mon Sep 17 00:00:00 2001
From: tharu-jwd <tharupahanjayawardana@gmail.com>
Date: Fri, 10 Apr 2026 12:20:52 +0530
Subject: [PATCH] close dead connections even if they have active subscriptions

---
 src/adapters/web-socket-adapter.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/adapters/web-socket-adapter.ts b/src/adapters/web-socket-adapter.ts
index ab1b9f7a..31e36fb2 100644
--- a/src/adapters/web-socket-adapter.ts
+++ b/src/adapters/web-socket-adapter.ts
@@ -129,7 +129,7 @@ export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter
   }
 
   public onHeartbeat(): void {
-    if (!this.alive && !this.subscriptions.size) {
+    if (!this.alive) {
       console.error(`web-socket-adapter: pong timeout for client ${this.clientId} (${this.getClientAddress()})`)
       this.client.close()
       return