)
let poolReady = 0
pool1.emitter.on(PoolEvents.ready, () => ++poolReady)
- if (!pool1.info.ready) {
- await waitPoolEvents(pool1, PoolEvents.ready, 1)
- }
+ await waitPoolEvents(pool1, 'ready', 1)
expect(poolReady).toBe(1)
})
- it("Verify that 'busy' event is emitted", async () => {
+ it("Verify that 'busy' event is emitted", () => {
let poolBusy = 0
pool.emitter.on(PoolEvents.busy, () => ++poolBusy)
for (let i = 0; i < numberOfThreads * 2; i++) {