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

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