docs: refactor TS example

[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, 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 })
      }, 1000)
    })
  }
}

export default new MyThreadWorker()