repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
refactor: refine circular buffer error message
[poolifier.git]
/
src
/
worker
/
abstract-worker.ts
diff --git
a/src/worker/abstract-worker.ts
b/src/worker/abstract-worker.ts
index 2a5f1121521f15c193df29022aa755ed2aabee8f..bb6ac5666e0252195b4f1cafbda38471ec7fcf07 100644
(file)
--- a/
src/worker/abstract-worker.ts
+++ b/
src/worker/abstract-worker.ts
@@
-324,19
+324,27
@@
export abstract class AbstractWorker<
*/
protected messageListener (message: MessageValue<Data>): void {
this.checkMessageWorkerId(message)
*/
protected messageListener (message: MessageValue<Data>): void {
this.checkMessageWorkerId(message)
- if (message.statistics != null) {
+ const {
+ statistics,
+ checkActive,
+ taskFunctionOperation,
+ taskId,
+ data,
+ kill
+ } = message
+ if (statistics != null) {
// Statistics message received
// Statistics message received
- this.statistics =
message.
statistics
- } else if (
message.
checkActive != null) {
+ this.statistics = statistics
+ } else if (checkActive != null) {
// Check active message received
// Check active message received
-
message.
checkActive ? this.startCheckActive() : this.stopCheckActive()
- } else if (
message.
taskFunctionOperation != null) {
+ checkActive ? this.startCheckActive() : this.stopCheckActive()
+ } else if (taskFunctionOperation != null) {
// Task function operation message received
this.handleTaskFunctionOperationMessage(message)
// Task function operation message received
this.handleTaskFunctionOperationMessage(message)
- } else if (
message.taskId != null && message.
data != null) {
+ } else if (
taskId != null &&
data != null) {
// Task message received
this.run(message)
// Task message received
this.run(message)
- } else if (
message.
kill === true) {
+ } else if (kill === true) {
// Kill message received
this.handleKillMessage(message)
}
// Kill message received
this.handleKillMessage(message)
}