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 ca14133f2dafa7b1d6692f84459bafabb431e935..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
)
]
}
)
]
}
@@
-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: {