X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fcluster%2Fdynamic.test.js;h=c91447ee31b6fe1f23c048b9d25568f0bfd8d0db;hb=e4147fed0610be12b92f976ed274ae4737f785b5;hp=65dff559ab1618fb2395505fa055ea935821a6ae;hpb=dbca3be954130834defeb4084096272ecf660c5c;p=poolifier.git diff --git a/tests/pools/cluster/dynamic.test.js b/tests/pools/cluster/dynamic.test.js index 65dff559..c91447ee 100644 --- a/tests/pools/cluster/dynamic.test.js +++ b/tests/pools/cluster/dynamic.test.js @@ -11,7 +11,7 @@ describe('Dynamic cluster pool test suite', () => { max, './tests/worker-files/cluster/testWorker.js', { - errorHandler: e => console.error(e) + errorHandler: (e) => console.error(e) } ) @@ -59,9 +59,12 @@ describe('Dynamic cluster pool test suite', () => { it('Shutdown test', async () => { const exitPromise = waitWorkerEvents(pool, 'exit', min) + let poolDestroy = 0 + pool.emitter.on(PoolEvents.destroy, () => ++poolDestroy) await pool.destroy() const numberOfExitEvents = await exitPromise expect(numberOfExitEvents).toBe(min) + expect(poolDestroy).toBe(1) }) it('Validation of inputs test', () => { @@ -88,7 +91,7 @@ describe('Dynamic cluster pool test suite', () => { max, './tests/worker-files/cluster/longRunningWorkerHardBehavior.js', { - errorHandler: e => console.error(e), + errorHandler: (e) => console.error(e), onlineHandler: () => console.info('long executing worker is online'), exitHandler: () => console.info('long executing worker exited') } @@ -115,7 +118,7 @@ describe('Dynamic cluster pool test suite', () => { max, './tests/worker-files/cluster/longRunningWorkerSoftBehavior.js', { - errorHandler: e => console.error(e), + errorHandler: (e) => console.error(e), onlineHandler: () => console.info('long executing worker is online'), exitHandler: () => console.info('long executing worker exited') }