X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2Ftypescript%2Fwebsocket-server-pool%2Fws-cluster%2Fsrc%2Fworker.ts;h=5e758eb7d3f845e1d8508bf907bda9fa7fcbcc3d;hb=ef083f7bb73616d1bd9d9069471edcf6dbaec0c7;hp=c82c7e636f8199495720eccfa71a44db925c899b;hpb=3d49c6d2f943532974cefa71f13af2c313555d95;p=poolifier.git diff --git a/examples/typescript/websocket-server-pool/ws-cluster/src/worker.ts b/examples/typescript/websocket-server-pool/ws-cluster/src/worker.ts index c82c7e63..5e758eb7 100644 --- a/examples/typescript/websocket-server-pool/ws-cluster/src/worker.ts +++ b/examples/typescript/websocket-server-pool/ws-cluster/src/worker.ts @@ -22,6 +22,7 @@ class WebSocketServerWorker extends ClusterWorker { workerData?: WorkerData ): WorkerResponse => { const { port } = workerData as WorkerData + WebSocketServerWorker.wss = new WebSocketServer({ port }, () => { console.info( `⚡️[ws server]: WebSocket server is started in cluster worker at ws://localhost:${port}/` @@ -62,7 +63,11 @@ class WebSocketServerWorker extends ClusterWorker { } public constructor () { - super(WebSocketServerWorker.startWebSocketServer) + super(WebSocketServerWorker.startWebSocketServer, { + killHandler: () => { + WebSocketServerWorker.wss.close() + } + }) } }