X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fthread%2Ffixed.test.js;h=636121fd4812eb8705bb2aed57119e8b84f8bcfb;hb=3f7d99f5a6b9783554886f1850aa45c5bc237b65;hp=b2842f6e367eb7839053ce55844dc57bedf6ad12;hpb=079de9913bd2a225fe8f08c51be74b1f4d4a78d4;p=poolifier.git diff --git a/tests/pools/thread/fixed.test.js b/tests/pools/thread/fixed.test.js index b2842f6e..636121fd 100644 --- a/tests/pools/thread/fixed.test.js +++ b/tests/pools/thread/fixed.test.js @@ -87,7 +87,9 @@ describe('Fixed thread pool test suite', () => { ) let poolReady = 0 pool1.emitter.on(PoolEvents.ready, () => ++poolReady) - await waitPoolEvents(pool1, PoolEvents.ready, 1) + if (!pool1.info.ready) { + await waitPoolEvents(pool1, PoolEvents.ready, 1) + } expect(poolReady).toBe(1) }) @@ -163,6 +165,7 @@ describe('Fixed thread pool test suite', () => { expect(typeof inError.message === 'string').toBe(true) expect(inError.message).toBe('Error Message from ThreadWorker') expect(taskError).toStrictEqual({ + name: 'default', message: new Error('Error Message from ThreadWorker'), data }) @@ -191,6 +194,7 @@ describe('Fixed thread pool test suite', () => { expect(typeof inError.message === 'string').toBe(true) expect(inError.message).toBe('Error Message from ThreadWorker:async') expect(taskError).toStrictEqual({ + name: 'default', message: new Error('Error Message from ThreadWorker:async'), data })