examples/typescript/worker.ts

   1 import { ThreadWorker } from 'poolifier'
   2
   3 export interface MyData {
   4   ok: 0 | 1
   5 }
   6
   7 export interface MyResponse {
   8   message: string
   9   data?: MyData
  10 }
  11
  12 class MyThreadWorker extends ThreadWorker<MyData, MyResponse> {
  13   constructor () {
  14     super(async (data?: MyData) => await this.process(data), {
  15       maxInactiveTime: 60000
  16     })
  17   }
  18
  19   private async process (data?: MyData): Promise<MyResponse> {
  20     return await new Promise(resolve => {
  21       setTimeout(() => {
  22         resolve({ message: 'Hello from Worker :)', data })
  23       }, 1000)
  24     })
  25   }
  26 }
  27
  28 export default new MyThreadWorker()