repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
build: refine rollup configuration
[poolifier.git]
/
tests
/
test-utils.js
diff --git
a/tests/test-utils.js
b/tests/test-utils.js
index 177a5c28e5e13e57284318fb77ea58005bdc06dd..3963adecdba419b1d9d09437b08312ed02f631f9 100644
(file)
--- a/
tests/test-utils.js
+++ b/
tests/test-utils.js
@@
-1,7
+1,7
@@
-const {
WorkerFunctions } = require('./test-type
s')
+const {
TaskFunctions } = require('./test-types.j
s')
const waitWorkerEvents = async (pool, workerEvent, numberOfEventsToWait) => {
const waitWorkerEvents = async (pool, workerEvent, numberOfEventsToWait) => {
- return new Promise(resolve => {
+ return
await
new Promise(resolve => {
let events = 0
if (numberOfEventsToWait === 0) {
resolve(events)
let events = 0
if (numberOfEventsToWait === 0) {
resolve(events)
@@
-18,12
+18,12
@@
const waitWorkerEvents = async (pool, workerEvent, numberOfEventsToWait) => {
}
const waitPoolEvents = async (pool, poolEvent, numberOfEventsToWait) => {
}
const waitPoolEvents = async (pool, poolEvent, numberOfEventsToWait) => {
- return new Promise(resolve => {
+ return
await
new Promise(resolve => {
let events = 0
if (numberOfEventsToWait === 0) {
resolve(events)
}
let events = 0
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)
@@
-33,16
+33,16
@@
const waitPoolEvents = async (pool, poolEvent, numberOfEventsToWait) => {
}
const sleep = async ms => {
}
const sleep = async ms => {
- return new Promise(resolve => setTimeout(resolve, ms))
+ return
await
new Promise(resolve => setTimeout(resolve, ms))
}
}
-const sleep
Worker
Function = async (
+const sleep
Task
Function = async (
data,
ms,
rejection = false,
rejectionMessage = ''
) => {
data,
ms,
rejection = false,
rejectionMessage = ''
) => {
- return new Promise((resolve, reject) => {
+ return
await
new Promise((resolve, reject) => {
setTimeout(
() =>
rejection === true
setTimeout(
() =>
rejection === true
@@
-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
}