X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fabstract%2Fabstract-pool.test.js;h=a5976d99d88d16d381d2e82cd56889ec91539d91;hb=b591c1fa9418d7a120097a30b19fa60212fbc3eb;hp=8a8f779c41603f09859bf475d0c55406a04fa918;hpb=574b351dcb46b90a6a8d0ffb15b5016392e5a63f;p=poolifier.git diff --git a/tests/pools/abstract/abstract-pool.test.js b/tests/pools/abstract/abstract-pool.test.js index 8a8f779c..a5976d99 100644 --- a/tests/pools/abstract/abstract-pool.test.js +++ b/tests/pools/abstract/abstract-pool.test.js @@ -23,6 +23,10 @@ describe('Abstract pool test suite', () => { } } + afterEach(() => { + sinon.restore() + }) + it('Simulate pool creation from a non main thread/process', () => { expect( () => @@ -214,7 +218,7 @@ describe('Abstract pool test suite', () => { expect(pool.opts.enableTasksQueue).toBe(true) expect(pool.opts.tasksQueueOptions).toStrictEqual({ concurrency: 2, - queueMaxSize: 4 + size: 4 }) expect(pool.opts.workerChoiceStrategy).toBe( WorkerChoiceStrategies.LEAST_USED @@ -493,13 +497,13 @@ describe('Abstract pool test suite', () => { expect(pool.opts.enableTasksQueue).toBe(true) expect(pool.opts.tasksQueueOptions).toStrictEqual({ concurrency: 1, - queueMaxSize: 4 + size: 4 }) pool.enableTasksQueue(true, { concurrency: 2 }) expect(pool.opts.enableTasksQueue).toBe(true) expect(pool.opts.tasksQueueOptions).toStrictEqual({ concurrency: 2, - queueMaxSize: 4 + size: 4 }) pool.enableTasksQueue(false) expect(pool.opts.enableTasksQueue).toBe(false) @@ -515,12 +519,12 @@ describe('Abstract pool test suite', () => { ) expect(pool.opts.tasksQueueOptions).toStrictEqual({ concurrency: 1, - queueMaxSize: 4 + size: 4 }) pool.setTasksQueueOptions({ concurrency: 2 }) expect(pool.opts.tasksQueueOptions).toStrictEqual({ concurrency: 2, - queueMaxSize: 4 + size: 4 }) expect(() => pool.setTasksQueueOptions('invalidTasksQueueOptions') @@ -540,17 +544,17 @@ describe('Abstract pool test suite', () => { expect(() => pool.setTasksQueueOptions({ concurrency: 0.2 })).toThrowError( new TypeError('Invalid worker node tasks concurrency: must be an integer') ) - expect(() => pool.setTasksQueueOptions({ queueMaxSize: 0 })).toThrowError( + expect(() => pool.setTasksQueueOptions({ size: 0 })).toThrowError( new RangeError( 'Invalid worker node tasks queue max size: 0 is a negative integer or zero' ) ) - expect(() => pool.setTasksQueueOptions({ queueMaxSize: -1 })).toThrowError( + expect(() => pool.setTasksQueueOptions({ size: -1 })).toThrowError( new RangeError( 'Invalid worker node tasks queue max size: -1 is a negative integer or zero' ) ) - expect(() => pool.setTasksQueueOptions({ queueMaxSize: 0.2 })).toThrowError( + expect(() => pool.setTasksQueueOptions({ size: 0.2 })).toThrowError( new TypeError( 'Invalid worker node tasks queue max size: must be an integer' )