X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2Ftypescript%2Fwebsocket-server-pool%2Fws-hybrid%2Fsrc%2Fwebsocket-server-worker.ts;h=ec6a3d18736f119cb27f5e32988fe464f5d2d3d4;hb=88c31884cb650840fe3896baa0c53280fb1479e3;hp=7b4aa070f591a7240d6be5e6f9c5e842398e0d0c;hpb=d0ed34c9a6f9896c16b1b963e87217bbf75f3393;p=poolifier.git diff --git a/examples/typescript/websocket-server-pool/ws-hybrid/src/websocket-server-worker.ts b/examples/typescript/websocket-server-pool/ws-hybrid/src/websocket-server-worker.ts index 7b4aa070..ec6a3d18 100644 --- a/examples/typescript/websocket-server-pool/ws-hybrid/src/websocket-server-worker.ts +++ b/examples/typescript/websocket-server-pool/ws-hybrid/src/websocket-server-worker.ts @@ -15,7 +15,7 @@ import { } from './types.js' const emptyFunction = (): void => { - /** Intentional */ + /* Intentional */ } class WebSocketServerWorker extends ClusterWorker< @@ -31,7 +31,7 @@ ClusterWorkerResponse private static readonly startWebSocketServer = ( workerData?: ClusterWorkerData ): ClusterWorkerResponse => { - const { port, workerFile, minWorkers, maxWorkers } = + const { port, workerFile, minWorkers, maxWorkers, ...poolOptions } = workerData as ClusterWorkerData WebSocketServerWorker.requestHandlerPool = new DynamicThreadPool< @@ -41,7 +41,7 @@ ClusterWorkerResponse minWorkers ?? 1, maxWorkers ?? availableParallelism(), workerFile, - workerData + poolOptions ) WebSocketServerWorker.wss = new WebSocketServer({ port }, () => { @@ -50,7 +50,7 @@ ClusterWorkerResponse ) }) - 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( @@ -61,7 +61,7 @@ ClusterWorkerResponse case MessageType.echo: WebSocketServerWorker.requestHandlerPool .execute({ data }, 'echo') - .then((response) => { + .then(response => { ws.send( JSON.stringify({ type: MessageType.echo, @@ -75,7 +75,7 @@ ClusterWorkerResponse case MessageType.factorial: WebSocketServerWorker.requestHandlerPool .execute({ data }, 'factorial') - .then((response) => { + .then(response => { ws.send( JSON.stringify({ type: MessageType.factorial,