diff --git a/src/adapters/web-socket-adapter.ts b/src/adapters/web-socket-adapter.ts index 5330578..0898d39 100644 --- a/src/adapters/web-socket-adapter.ts +++ b/src/adapters/web-socket-adapter.ts @@ -68,7 +68,7 @@ export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter family: address.indexOf(':') >= 0 ? 'ipv6' : 'ipv4', }) - console.log(`web-socket-adapter: new client ${this.clientId} (${this.getClientAddress()})`) + console.log(`web-socket-adapter: new client ${this.clientId} (${this.getClientAddress()}) - ${(this.webSocketServer as any).webSocketServer.clients.size} total on worker ${process.pid}`) this.client .on('error', (error) => { @@ -276,6 +276,6 @@ export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter this.removeAllListeners() this.client.removeAllListeners() - console.error(`web-socket-adapter: disconnected client ${this.clientId} (${this.getClientAddress()})`) + console.error(`web-socket-adapter: disconnected client ${this.clientId} (${this.getClientAddress()}) - ${(this.webSocketServer as any).webSocketServer.clients.size} total on worker ${process.pid}`) } } diff --git a/src/adapters/web-socket-server-adapter.ts b/src/adapters/web-socket-server-adapter.ts index 7c22d5b..e07c66d 100644 --- a/src/adapters/web-socket-server-adapter.ts +++ b/src/adapters/web-socket-server-adapter.ts @@ -95,8 +95,6 @@ export class WebSocketServerAdapter extends WebServerAdapter implements IWebSock return } - console.log('web-socket-server-adapter: connected clients:', this.webSocketServer.clients.size) - this.webSocketsAdapters.set(client, this.createWebSocketAdapter([client, req, this])) }