repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'master' of github.com:poolifier/poolifier into feature/task-functions
[poolifier.git]
/
tests
/
test-utils.js
diff --git
a/tests/test-utils.js
b/tests/test-utils.js
index 177a5c28e5e13e57284318fb77ea58005bdc06dd..b55f76215e3d8f651281148eb8c57be59e7cc9fb 100644
(file)
--- a/
tests/test-utils.js
+++ b/
tests/test-utils.js
@@
-1,4
+1,4
@@
-const {
Worker
Functions } = require('./test-types')
+const {
Task
Functions } = require('./test-types')
const waitWorkerEvents = async (pool, workerEvent, numberOfEventsToWait) => {
return new Promise(resolve => {
const waitWorkerEvents = async (pool, workerEvent, numberOfEventsToWait) => {
return new Promise(resolve => {
@@
-23,7
+23,7
@@
const waitPoolEvents = async (pool, poolEvent, numberOfEventsToWait) => {
if (numberOfEventsToWait === 0) {
resolve(events)
}
if (numberOfEventsToWait === 0) {
resolve(events)
}
- pool
?.emitter
.on(poolEvent, () => {
+ pool
.emitter?
.on(poolEvent, () => {
++events
if (events === numberOfEventsToWait) {
resolve(events)
++events
if (events === numberOfEventsToWait) {
resolve(events)
@@
-36,7
+36,7
@@
const sleep = async ms => {
return new Promise(resolve => setTimeout(resolve, ms))
}
return new Promise(resolve => setTimeout(resolve, ms))
}
-const sleep
Worker
Function = async (
+const sleep
Task
Function = async (
data,
ms,
rejection = false,
data,
ms,
rejection = false,
@@
-97,13
+97,13
@@
const factorial = n => {
return factorial(n - 1) * n
}
return factorial(n - 1) * n
}
-const execute
Worker
Function = data => {
+const execute
Task
Function = data => {
switch (data.function) {
switch (data.function) {
- case
Worker
Functions.jsonIntegerSerialization:
+ case
Task
Functions.jsonIntegerSerialization:
return jsonIntegerSerialization(data.n || 100)
return jsonIntegerSerialization(data.n || 100)
- case
Worker
Functions.fibonacci:
+ case
Task
Functions.fibonacci:
return fibonacci(data.n || 25)
return fibonacci(data.n || 25)
- case
Worker
Functions.factorial:
+ case
Task
Functions.factorial:
return factorial(data.n || 100)
default:
throw new Error('Unknown worker function')
return factorial(data.n || 100)
default:
throw new Error('Unknown worker function')
@@
-111,13
+111,13
@@
const executeWorkerFunction = data => {
}
module.exports = {
}
module.exports = {
- execute
Worker
Function,
+ execute
Task
Function,
factorial,
fibonacci,
generateRandomInteger,
jsonIntegerSerialization,
sleep,
factorial,
fibonacci,
generateRandomInteger,
jsonIntegerSerialization,
sleep,
- sleep
Worker
Function,
+ sleep
Task
Function,
waitPoolEvents,
waitWorkerEvents
}
waitPoolEvents,
waitWorkerEvents
}