examples/typescript/worker.ts

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