8350ebf94b1c36179334f1d9735884227f5b40ed
1 import { ThreadWorker
} from
'poolifier'
3 export interface MyData
{
7 export interface MyResponse
{
12 class MyThreadWorker
extends ThreadWorker
<MyData
, Promise
<MyResponse
>> {
14 super(data
=> this.process(data
), {
15 maxInactiveTime
: 60000,
20 private async process (data
: MyData
): Promise
<MyResponse
> {
21 return new Promise(resolve
=> {
23 resolve({ message
: 'Hello from Worker :)', data
})
29 export default new MyThreadWorker()