Data = unknown,
Response = unknown
> extends AsyncResource {
+ /**
+ * Worker id.
+ */
+ protected abstract id: number
/**
* Task function(s) processed by the worker when the pool's `execution` function is invoked.
*/
this.sendToMainWorker({
data: res,
taskPerformance,
+ workerId: this.id,
id: message.id
})
} catch (e) {
message: err,
data: message.data
},
+ workerId: this.id,
id: message.id
})
} finally {
this.sendToMainWorker({
data: res,
taskPerformance,
+ workerId: this.id,
id: message.id
})
return null
message: err,
data: message.data
},
+ workerId: this.id,
id: message.id
})
})