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=eabf72ebb30449aaec103e485d8d1105d3bca333;hb=1bbea1bc234785d741e62985e0ffb52aafa458d7;hp=ec6a3d18736f119cb27f5e32988fe464f5d2d3d4;hpb=a7263cc7976423d318bd3a82d1a60b2f39b6e2c5;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 ec6a3d18..eabf72eb 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 @@ -1,9 +1,10 @@ import { + availableParallelism, ClusterWorker, - DynamicThreadPool, - availableParallelism + DynamicThreadPool } from 'poolifier' import { type RawData, WebSocketServer } from 'ws' + import { type ClusterWorkerData, type ClusterWorkerResponse, @@ -32,7 +33,7 @@ ClusterWorkerResponse workerData?: ClusterWorkerData ): ClusterWorkerResponse => { const { port, workerFile, minWorkers, maxWorkers, ...poolOptions } = - workerData as ClusterWorkerData + workerData! WebSocketServerWorker.requestHandlerPool = new DynamicThreadPool< ThreadWorkerData, @@ -68,7 +69,7 @@ ClusterWorkerResponse data: response.data }) ) - return null + return undefined }) .catch(emptyFunction) break @@ -82,7 +83,7 @@ ClusterWorkerResponse data: response.data }) ) - return null + return undefined }) .catch(emptyFunction) break