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