examples/typescript/websocket-server-pool/ws-worker_threads/src/worker.ts

   1 import { ThreadWorker } from 'poolifier'
   2 import {
   3   type DataPayload,
   4   type WorkerData,
   5   type WorkerResponse
   6 } from './types.js'
   7
   8 class RequestHandlerWorker<
   9   Data extends WorkerData<DataPayload>,
  10   Response extends WorkerResponse<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(
  28               workerData?.data?.number as number
  29             )
  30           }
  31         } as unknown as Response
  32       }
  33     })
  34   }
  35 }
  36
  37 export const requestHandlerWorker = new RequestHandlerWorker<
  38 WorkerData<DataPayload>,
  39 WorkerResponse<DataPayload>
  40 >()