const { WorkerFunctions } = require('../../test-types')
const { waitPoolEvents, waitWorkerEvents } = require('../../test-utils')
-describe('Fixed thread pool test suite', async () => {
+describe('Fixed thread pool test suite', () => {
const numberOfThreads = 6
const pool = new FixedThreadPool(
numberOfThreads,
errorHandler: e => console.error(e)
}
)
- let poolReady = 0
- pool.emitter.on(PoolEvents.ready, () => ++poolReady)
- await waitPoolEvents(pool, PoolEvents.ready, 1)
const queuePool = new FixedThreadPool(
numberOfThreads,
'./tests/worker-files/thread/testWorker.js',
})
it("Verify that 'ready' event is emitted", async () => {
+ const pool1 = new FixedThreadPool(
+ numberOfThreads,
+ './tests/worker-files/thread/testWorker.js',
+ {
+ errorHandler: e => console.error(e)
+ }
+ )
+ let poolReady = 0
+ pool1.emitter.on(PoolEvents.ready, () => ++poolReady)
+ if (!pool1.info.ready) {
+ await waitPoolEvents(pool1, PoolEvents.ready, 1)
+ }
expect(poolReady).toBe(1)
})
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
})
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
})