X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2Ftypescript%2Fhttp-server-pool%2Ffastify-hybrid%2Fsrc%2Frequest-handler-worker.ts;h=5297de12846601c580c09773eee7e8bee34163c3;hb=e69cc10a0b0e531f4bb7a33fc8728741d9a82533;hp=1b35b44b136b3c1142ebd33ad3e5fe9f8d7b4fbf;hpb=3b3115396965edad0cf3fefc4f9081977310da34;p=poolifier.git diff --git a/examples/typescript/http-server-pool/fastify-hybrid/src/request-handler-worker.ts b/examples/typescript/http-server-pool/fastify-hybrid/src/request-handler-worker.ts index 1b35b44b..5297de12 100644 --- a/examples/typescript/http-server-pool/fastify-hybrid/src/request-handler-worker.ts +++ b/examples/typescript/http-server-pool/fastify-hybrid/src/request-handler-worker.ts @@ -1,21 +1,28 @@ import { ThreadWorker } from 'poolifier' -import { - type BodyPayload, - type ThreadWorkerData, - type ThreadWorkerResponse -} from './types.js' -const factorial: (n: number) => number = n => { - if (n === 0) { - return 1 - } - return factorial(n - 1) * n -} +import type { + DataPayload, + ThreadWorkerData, + ThreadWorkerResponse, +} from './types.js' class RequestHandlerWorker< - Data extends ThreadWorkerData, - Response extends ThreadWorkerResponse + Data extends ThreadWorkerData, + Response extends ThreadWorkerResponse > extends ThreadWorker { + 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 + } + } + public constructor () { super({ echo: (workerData?: Data) => { @@ -23,14 +30,19 @@ class RequestHandlerWorker< }, factorial: (workerData?: Data) => { return { - body: { number: factorial(workerData?.body?.number as number) } + data: { + number: RequestHandlerWorker.factorial( + // eslint-disable-next-line @typescript-eslint/no-non-null-assertion + workerData!.data.number! + ).toString(), + }, } as unknown as Response - } + }, }) } } export const requestHandlerWorker = new RequestHandlerWorker< -ThreadWorkerData, -ThreadWorkerResponse + ThreadWorkerData, + ThreadWorkerResponse >()