X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2Ftypescript%2Fwebsocket-server-pool%2Fws-cluster%2Fsrc%2Fworker.ts;h=143dc6db38deac7f40f27001b3aa51e7ba9c2e2b;hb=78eba20716292b21dd67bdc00a9fb59137283f89;hp=efe0facdc900b96ae4b4d49d36da3729a598147a;hpb=8ebe6c308dc1fc3202980126da043b2855d24780;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 efe0facd..143dc6db 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() + } + }) } }