X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Ftest-utils.js;h=0e71c718a8eee83c85011e10f417725811ae34f8;hb=0e2c24b4aaed93a6768127f49d898ac427faa147;hp=f650af789867c1e87d56e963a210a9f4320a02c0;hpb=f821a8411ccb1217a6deb9d2e082eecc4ba6d9b4;p=poolifier.git diff --git a/tests/test-utils.js b/tests/test-utils.js index f650af78..0e71c718 100644 --- a/tests/test-utils.js +++ b/tests/test-utils.js @@ -4,14 +4,17 @@ class TestUtils { static async waitExits (pool, numberOfExitEventsToWait) { return new Promise(resolve => { let exitEvents = 0 - pool.workers.forEach(w => { - w.on('exit', () => { - exitEvents++ + if (numberOfExitEventsToWait === 0) { + resolve(exitEvents) + } + for (const workerNode of pool.workerNodes) { + workerNode.worker.on('exit', () => { + ++exitEvents if (exitEvents === numberOfExitEventsToWait) { resolve(exitEvents) } }) - }) + } }) } @@ -59,7 +62,6 @@ class TestUtils { /** * Intentionally inefficient implementation. - * * @param {number} n - The number of fibonacci numbers to generate. * @returns {number} - The nth fibonacci number. */ @@ -70,16 +72,14 @@ class TestUtils { /** * Intentionally inefficient implementation. - * * @param {number} n - The number to calculate the factorial of. * @returns {number} - The factorial of n. */ static factorial (n) { if (n === 0) { return 1 - } else { - return TestUtils.factorial(n - 1) * n } + return TestUtils.factorial(n - 1) * n } static executeWorkerFunction (data) {