repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
fix: fix possible null exception at handling task execution response
[poolifier.git]
/
src
/
pools
/
worker-node.ts
diff --git
a/src/pools/worker-node.ts
b/src/pools/worker-node.ts
index 7a6a1500f962e4cc948ad593f3f40e45d49e53ad..d80c03d80f00edc474da050ca41c8297c12142dd 100644
(file)
--- a/
src/pools/worker-node.ts
+++ b/
src/pools/worker-node.ts
@@
-49,7
+49,7
@@
export class WorkerNode<Worker extends IWorker, Data = unknown>
* Constructs a new worker node.
*
* @param type - The worker type.
* Constructs a new worker node.
*
* @param type - The worker type.
- * @param filePath -
The worker file path
.
+ * @param filePath -
Path to the worker file
.
* @param opts - The worker node options.
*/
constructor (type: WorkerType, filePath: string, opts: WorkerNodeOptions) {
* @param opts - The worker node options.
*/
constructor (type: WorkerType, filePath: string, opts: WorkerNodeOptions) {
@@
-146,25
+146,25
@@
export class WorkerNode<Worker extends IWorker, Data = unknown>
/** @inheritdoc */
public registerWorkerEventHandler (
event: string,
/** @inheritdoc */
public registerWorkerEventHandler (
event: string,
-
listen
er:
+
handl
er:
| OnlineHandler<Worker>
| MessageHandler<Worker>
| ErrorHandler<Worker>
| ExitHandler<Worker>
): void {
| OnlineHandler<Worker>
| MessageHandler<Worker>
| ErrorHandler<Worker>
| ExitHandler<Worker>
): void {
- this.worker.on(event,
listen
er)
+ this.worker.on(event,
handl
er)
}
/** @inheritdoc */
public registerOnceWorkerEventHandler (
event: string,
}
/** @inheritdoc */
public registerOnceWorkerEventHandler (
event: string,
-
listen
er:
+
handl
er:
| OnlineHandler<Worker>
| MessageHandler<Worker>
| ErrorHandler<Worker>
| ExitHandler<Worker>
): void {
| OnlineHandler<Worker>
| MessageHandler<Worker>
| ErrorHandler<Worker>
| ExitHandler<Worker>
): void {
- this.worker.once(event,
listen
er)
+ this.worker.once(event,
handl
er)
}
/** @inheritdoc */
}
/** @inheritdoc */