)
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)
})
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
})