X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=tests%2Fpools%2Fcluster%2Fdynamic.test.js;h=ddf42501d43ed63a3f84831b3aa2b13ba44fc701;hb=e65c6cd9a3d6ed2e5b8af95120a5aa070101e945;hp=6ce3d0a1ef978bd138a4fd8d0eb38ed596366edb;hpb=e1ffb94fcac39a7459c47edaa086a7729a1dec44;p=poolifier.git diff --git a/tests/pools/cluster/dynamic.test.js b/tests/pools/cluster/dynamic.test.js index 6ce3d0a1..ddf42501 100644 --- a/tests/pools/cluster/dynamic.test.js +++ b/tests/pools/cluster/dynamic.test.js @@ -1,6 +1,6 @@ const { expect } = require('expect') const { DynamicClusterPool } = require('../../../lib/index') -const WorkerFunctions = require('../../test-types') +const { WorkerFunctions } = require('../../test-types') const TestUtils = require('../../test-utils') describe('Dynamic cluster pool test suite', () => { @@ -27,11 +27,10 @@ describe('Dynamic cluster pool test suite', () => { }) it('Verify that new workers are created when required, max size is not exceeded and that after a while new workers will die', async () => { - const promises = [] let poolBusy = 0 - pool.emitter.on('busy', () => poolBusy++) + pool.emitter.on('busy', () => ++poolBusy) for (let i = 0; i < max * 2; i++) { - promises.push(pool.execute()) + pool.execute() } expect(pool.workers.length).toBeLessThanOrEqual(max) expect(pool.workers.length).toBeGreaterThan(min)