79819d9853b345ccadfc0bb8428e4b4c9a3820c5
1 import { ThreadWorker
} from
'poolifier'
3 export interface MyData
{
7 export interface MyResponse
{
12 class MyThreadWorker
extends ThreadWorker
<MyData
, MyResponse
> {
14 super(async (data
?: MyData
) => await this.process(data
), {
15 maxInactiveTime
: 60000
19 private async process (data
?: MyData
): Promise
<MyResponse
> {
20 return await new Promise(resolve
=> {
22 resolve({ message
: 'Hello from Worker :)', data
})
28 export default new MyThreadWorker()