examples/typescript/http-server-pool/fastify-hybrid/src/request-handler-worker.ts

   1 import { ThreadWorker } from 'poolifier'
   2 import {
   3   type DataPayload,
   4   type ThreadWorkerData,
   5   type ThreadWorkerResponse
   6 } from './types.js'
   7
   8 class RequestHandlerWorker<
   9   Data extends ThreadWorkerData<DataPayload>,
  10   Response extends ThreadWorkerResponse<DataPayload>
  11 > extends ThreadWorker<Data, Response> {
  12   private static readonly factorial = (n: number): number => {
  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           data: {
  27             number: RequestHandlerWorker.factorial(workerData!.data.number!)
  28           }
  29         } as unknown as Response
  30       }
  31     })
  32   }
  33 }
  34
  35 export const requestHandlerWorker = new RequestHandlerWorker<
  36 ThreadWorkerData<DataPayload>,
  37 ThreadWorkerResponse<DataPayload>
  38 >()