Skip to content

Commit 1b518ae

Browse files
chore(deps): update ws
1 parent c9ccc96 commit 1b518ae

File tree

5 files changed

+852
-665
lines changed

5 files changed

+852
-665
lines changed

lib/Server.js

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1763,8 +1763,10 @@ class Server {
17631763

17641764
async stop() {
17651765
if (this.webSocketServer) {
1766-
process.nextTick(() => {
1767-
this.webSocketServer.implementation.close();
1766+
await new Promise((resolve) => {
1767+
this.webSocketServer.implementation.close(() => {
1768+
resolve();
1769+
});
17681770
});
17691771
}
17701772

lib/servers/WebsocketServer.js

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,10 @@ module.exports = class WebsocketServer extends BaseServer {
7070
this.implementation.on("close", () => {
7171
clearInterval(interval);
7272

73+
for (const ws of this.clients) {
74+
ws.terminate();
75+
}
76+
7377
this.clients.clear();
7478
});
7579
}

0 commit comments

Comments
 (0)