X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Ftest-utils.js;h=ef759824ce7e9b4d0294d84f2fa6dff02aba493a;hb=30d7f6e094a9b837fd85c74ef23188ab28e86644;hp=4478d29015ede00b981e8e66262204e2dc686a04;hpb=297d705dc3cac3e998e4ce25f1e7ee76c3b94be6;p=poolifier.git diff --git a/tests/test-utils.js b/tests/test-utils.js index 4478d290..ef759824 100644 --- a/tests/test-utils.js +++ b/tests/test-utils.js @@ -1,10 +1,11 @@ -const { TaskFunctions } = require('./test-types') +const { TaskFunctions } = require('./test-types.js') const waitWorkerEvents = async (pool, workerEvent, numberOfEventsToWait) => { return await new Promise(resolve => { let events = 0 if (numberOfEventsToWait === 0) { resolve(events) + return } for (const workerNode of pool.workerNodes) { workerNode.worker.on(workerEvent, () => { @@ -22,6 +23,7 @@ const waitPoolEvents = async (pool, poolEvent, numberOfEventsToWait) => { let events = 0 if (numberOfEventsToWait === 0) { resolve(events) + return } pool.emitter?.on(poolEvent, () => { ++events