diff --git a/src/adapters/web-socket-server-adapter.ts b/src/adapters/web-socket-server-adapter.ts index 9941e89..e25d575 100644 --- a/src/adapters/web-socket-server-adapter.ts +++ b/src/adapters/web-socket-server-adapter.ts @@ -73,13 +73,13 @@ export class WebSocketServerAdapter extends WebServerAdapter implements IWebSock ) } - protected onClose() { this.webSocketServer.clients.forEach((webSocket: WebSocket) => webSocket.terminate() ) console.debug(`worker ${process.pid} - websocket server closing`) clearInterval(this.heartbeatInterval) + this.removeAllListeners() this.webSocketServer.removeAllListeners() super.onClose() }