build(deps-dev): apply updates

[poolifier.git] / examples / typescript / worker.ts

import { ThreadWorker } from 'poolifier'

export interface MyData {
  ok: 0 | 1
}

export interface MyResponse {
  message: string
  data: MyData
}

class MyThreadWorker extends ThreadWorker<MyData, Promise<MyResponse>> {
  constructor () {
    super(async (data: MyData) => await this.process(data), {
      maxInactiveTime: 60000
    })
  }

  private async process (data: MyData): Promise<MyResponse> {
    return await new Promise(resolve => {
      setTimeout(() => {
        resolve({ message: 'Hello from Worker :)', data })
      }, 10000)
    })
  }
}

export default new MyThreadWorker()