repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
test: use arrow noop task function
[poolifier.git]
/
src
/
worker
/
abstract-worker.ts
diff --git
a/src/worker/abstract-worker.ts
b/src/worker/abstract-worker.ts
index f328bcfb52db2b0f0e5b366e5a121d80c38d08d1..2a5f1121521f15c193df29022aa755ed2aabee8f 100644
(file)
--- a/
src/worker/abstract-worker.ts
+++ b/
src/worker/abstract-worker.ts
@@
-26,7
+26,7
@@
import type {
} from './task-functions.js'
import {
checkTaskFunctionName,
} from './task-functions.js'
import {
checkTaskFunctionName,
- checkValidTaskFunctionEntry,
+ checkValidTaskFunction
Object
Entry,
checkValidWorkerOptions
} from './utils.js'
import { KillBehaviors, type WorkerOptions } from './worker-options.js'
checkValidWorkerOptions
} from './utils.js'
import { KillBehaviors, type WorkerOptions } from './worker-options.js'
@@
-145,7
+145,7
@@
export abstract class AbstractWorker<
Response
>
}
Response
>
}
- checkValidTaskFunctionEntry<Data, Response>(name, fnObj)
+ checkValidTaskFunction
Object
Entry<Data, Response>(name, fnObj)
fnObj.taskFunction = fnObj.taskFunction.bind(this)
if (firstEntry) {
this.taskFunctions.set(DEFAULT_TASK_NAME, fnObj)
fnObj.taskFunction = fnObj.taskFunction.bind(this)
if (firstEntry) {
this.taskFunctions.set(DEFAULT_TASK_NAME, fnObj)
@@
-200,7
+200,7
@@
export abstract class AbstractWorker<
if (typeof fn === 'function') {
fn = { taskFunction: fn } satisfies TaskFunctionObject<Data, Response>
}
if (typeof fn === 'function') {
fn = { taskFunction: fn } satisfies TaskFunctionObject<Data, Response>
}
- checkValidTaskFunctionEntry<Data, Response>(name, fn)
+ checkValidTaskFunction
Object
Entry<Data, Response>(name, fn)
fn.taskFunction = fn.taskFunction.bind(this)
if (
this.taskFunctions.get(name) ===
fn.taskFunction = fn.taskFunction.bind(this)
if (
this.taskFunctions.get(name) ===