repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge dependabot/npm_and_yarn/examples/typescript/http-server-pool/fastify-cluster...
[poolifier.git]
/
src
/
worker
/
abstract-worker.ts
diff --git
a/src/worker/abstract-worker.ts
b/src/worker/abstract-worker.ts
index a0d78dbd08f2023e38cd37dbff6dbc74064168fb..5b3c3a3f06596b00fad84e691875b438325bc600 100644
(file)
--- a/
src/worker/abstract-worker.ts
+++ b/
src/worker/abstract-worker.ts
@@
-268,7
+268,7
@@
export abstract class AbstractWorker<
names[names.indexOf(DEFAULT_TASK_NAME)],
defaultTaskFunctionName,
...names.filter(
names[names.indexOf(DEFAULT_TASK_NAME)],
defaultTaskFunctionName,
...names.filter(
-
(name)
=> name !== DEFAULT_TASK_NAME && name !== defaultTaskFunctionName
+
name
=> name !== DEFAULT_TASK_NAME && name !== defaultTaskFunctionName
)
]
}
)
]
}
@@
-351,7
+351,7
@@
export abstract class AbstractWorker<
protected handleKillMessage (message: MessageValue<Data>): void {
this.stopCheckActive()
if (isAsyncFunction(this.opts.killHandler)) {
protected handleKillMessage (message: MessageValue<Data>): void {
this.stopCheckActive()
if (isAsyncFunction(this.opts.killHandler)) {
-
;
(this.opts.killHandler?.() as Promise<void>)
+ (this.opts.killHandler?.() as Promise<void>)
.then(() => {
this.sendToMainWorker({ kill: 'success', workerId: this.id })
return null
.then(() => {
this.sendToMainWorker({ kill: 'success', workerId: this.id })
return null
@@
-545,7
+545,7
@@
export abstract class AbstractWorker<
const { name, taskId, data } = task
let taskPerformance = this.beginTaskPerformance(name)
fn(data)
const { name, taskId, data } = task
let taskPerformance = this.beginTaskPerformance(name)
fn(data)
- .then(
(res)
=> {
+ .then(
res
=> {
taskPerformance = this.endTaskPerformance(taskPerformance)
this.sendToMainWorker({
data: res,
taskPerformance = this.endTaskPerformance(taskPerformance)
this.sendToMainWorker({
data: res,
@@
-555,7
+555,7
@@
export abstract class AbstractWorker<
})
return null
})
})
return null
})
- .catch(
(e)
=> {
+ .catch(
e
=> {
const errorMessage = this.handleError(e as Error | string)
this.sendToMainWorker({
taskError: {
const errorMessage = this.handleError(e as Error | string)
this.sendToMainWorker({
taskError: {