X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Ftest-utils.js;h=ceaff7be4c605140c546d1773493b56dcfb1e309;hb=024daf59a8f93e67b7a307d1b5690ba564c80bab;hp=cba320a75896311e11d7b0b69ff27cf721dd0807;hpb=fe2dcd443af649ee75e8e66a3cff4174f072b015;p=poolifier.git diff --git a/tests/test-utils.js b/tests/test-utils.js index cba320a7..ceaff7be 100644 --- a/tests/test-utils.js +++ b/tests/test-utils.js @@ -1,17 +1,17 @@ const { WorkerFunctions } = require('./test-types') class TestUtils { - static async waitWorkerExits (pool, numberOfExitEventsToWait) { + static async waitWorkerEvents (pool, workerEvent, numberOfEventsToWait) { return new Promise(resolve => { - let exitEvents = 0 - if (numberOfExitEventsToWait === 0) { - resolve(exitEvents) + let events = 0 + if (numberOfEventsToWait === 0) { + resolve(events) } for (const workerNode of pool.workerNodes) { - workerNode.worker.on('exit', () => { - ++exitEvents - if (exitEvents === numberOfExitEventsToWait) { - resolve(exitEvents) + workerNode.worker.on(workerEvent, () => { + ++events + if (events === numberOfEventsToWait) { + resolve(events) } }) } @@ -81,7 +81,7 @@ class TestUtils { * @returns {number} - The nth fibonacci number. */ static fibonacci (n) { - if (n <= 1) return 1 + if (n <= 1) return n return TestUtils.fibonacci(n - 1) + TestUtils.fibonacci(n - 2) }