1 import { ThreadWorker
} from
'poolifier'
3 export interface MyData
{
7 export interface MyResponse
{
12 class MyThreadWorker
extends ThreadWorker
<MyData
, Promise
<MyResponse
>> {
14 // eslint-disable-next-line @typescript-eslint/promise-function-async
15 super((data
: MyData
) => this.process(data
), {
16 maxInactiveTime
: 60000,
21 private async process (data
: MyData
): Promise
<MyResponse
> {
22 return await new Promise(resolve
=> {
24 resolve({ message
: 'Hello from Worker :)', data
})
30 export default new MyThreadWorker()