refactor: cleanup type import
[poolifier.git] / examples / typescript / websocket-server-pool / ws-cluster / src / worker.ts
index c82c7e636f8199495720eccfa71a44db925c899b..5e758eb7d3f845e1d8508bf907bda9fa7fcbcc3d 100644 (file)
@@ -22,6 +22,7 @@ class WebSocketServerWorker extends ClusterWorker<WorkerData, WorkerResponse> {
     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<WorkerData, WorkerResponse> {
   }
 
   public constructor () {
-    super(WebSocketServerWorker.startWebSocketServer)
+    super(WebSocketServerWorker.startWebSocketServer, {
+      killHandler: () => {
+        WebSocketServerWorker.wss.close()
+      }
+    })
   }
 }