diff --git a/packages/platform-ws/adapters/ws-adapter.ts b/packages/platform-ws/adapters/ws-adapter.ts index 770a5f9963a..4111e894276 100644 --- a/packages/platform-ws/adapters/ws-adapter.ts +++ b/packages/platform-ws/adapters/ws-adapter.ts @@ -158,6 +158,16 @@ export class WsAdapter extends AbstractWsAdapter { client.on(CLOSE_EVENT, callback); } + public async close(server: any) { + const closeEventSignal = new Promise((resolve, reject) => + server.close(err => (err ? reject(err) : resolve(undefined))), + ); + for (const ws of server.clients) { + ws.terminate(); + } + await closeEventSignal; + } + public async dispose() { const closeEventSignals = Array.from(this.httpServersRegistry) .filter(([port]) => port !== UNDERLYING_HTTP_SERVER_PORT)