examples/typescript/http-server-pool/fastify-worker_threads/src/worker.ts

   1 import { ThreadWorker } from 'poolifier'
   2 import {
   3   type BodyPayload,
   4   type WorkerData,
   5   type WorkerResponse
   6 } from './types.js'
   7
   8 class RequestHandlerWorker<
   9   Data extends WorkerData<BodyPayload>,
  10   Response extends WorkerResponse<BodyPayload>
  11 > extends ThreadWorker<Data, Response> {
  12   private static readonly factorial: (n: number) => number = n => {
  13     if (n === 0) {
  14       return 1
  15     }
  16     return RequestHandlerWorker.factorial(n - 1) * n
  17   }
  18
  19   public constructor () {
  20     super({
  21       echo: (workerData?: Data) => {
  22         return workerData as unknown as Response
  23       },
  24       factorial: (workerData?: Data) => {
  25         return {
  26           body: {
  27             number: RequestHandlerWorker.factorial(
  28               workerData?.body?.number as number
  29             )
  30           }
  31         } as unknown as Response
  32       }
  33     })
  34   }
  35 }
  36
  37 export const requestHandlerWorker = new RequestHandlerWorker<
  38 WorkerData<BodyPayload>,
  39 WorkerResponse<BodyPayload>
  40 >()