X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2Ftypescript%2Fwebsocket-server-pool%2Fws-cluster%2Fsrc%2Fworker.ts;h=232382f609977568a783a5f779300ab86d111567;hb=b1d4f434444dd51c9006ab9b515d717c3d7f27a8;hp=18ece026c891efb3106499667027a1a2aba0b73a;hpb=67f3f2d6cb8f915ec71f81c4533ab80a6c6a6f0f;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 18ece026..232382f6 100644 --- a/examples/typescript/websocket-server-pool/ws-cluster/src/worker.ts +++ b/examples/typescript/websocket-server-pool/ws-cluster/src/worker.ts @@ -1,5 +1,6 @@ import { ClusterWorker } from 'poolifier' import { type RawData, WebSocketServer } from 'ws' + import { type DataPayload, type MessagePayload, @@ -11,11 +12,17 @@ import { class WebSocketServerWorker extends ClusterWorker { private static wss: WebSocketServer - private static readonly factorial = (n: number): number => { - if (n === 0) { - return 1 + private static readonly factorial = (n: number | bigint): bigint => { + if (n === 0 || n === 1) { + return 1n + } else { + n = BigInt(n) + let factorial = 1n + for (let i = 1n; i <= n; i++) { + factorial *= i + } + return factorial } - return WebSocketServerWorker.factorial(n - 1) * n } private static readonly startWebSocketServer = ( @@ -47,12 +54,15 @@ class WebSocketServerWorker extends ClusterWorker { break case MessageType.factorial: ws.send( - JSON.stringify({ - type: MessageType.factorial, - data: { - number: WebSocketServerWorker.factorial(data.number!) - } - }) + JSON.stringify( + { + type: MessageType.factorial, + data: { + number: WebSocketServerWorker.factorial(data.number!) + } + }, + (_, v) => (typeof v === 'bigint' ? v.toString() : v) + ) ) break }