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=f4d1dbd1592e24d7a09f35013c3e0f0762240254;hp=7785a0d6d2f2191f33a9e362853971bd0f86f1c3;hpb=89757908a0cf61d60dcf28323c5c23c4ef66fcf2;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 7785a0d6..5e758eb7 100644 --- a/examples/typescript/websocket-server-pool/ws-cluster/src/worker.ts +++ b/examples/typescript/websocket-server-pool/ws-cluster/src/worker.ts @@ -8,7 +8,7 @@ import { type WorkerResponse } from './types.js' -const factorial: (n: number) => number = (n) => { +const factorial: (n: number) => number = n => { if (n === 0) { return 1 } @@ -22,13 +22,14 @@ 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}/` ) }) - WebSocketServerWorker.wss.on('connection', (ws) => { + WebSocketServerWorker.wss.on('connection', ws => { ws.on('error', console.error) ws.on('message', (message: RawData) => { const { type, data } = JSON.parse(