let poolReady = 0
pool.emitter.on(PoolEvents.ready, () => ++poolReady)
await waitPoolEvents(pool, PoolEvents.ready, 1)
let poolReady = 0
pool.emitter.on(PoolEvents.ready, () => ++poolReady)
await waitPoolEvents(pool, PoolEvents.ready, 1)
expect(poolReady).toBe(1)
await pool.destroy()
})
it("Verify that 'busy' event is emitted", async () => {
const promises = new Set()
expect(poolReady).toBe(1)
await pool.destroy()
})
it("Verify that 'busy' event is emitted", async () => {
const promises = new Set()
it('Shutdown test', async () => {
const exitPromise = waitWorkerEvents(pool, 'exit', numberOfThreads)
it('Shutdown test', async () => {
const exitPromise = waitWorkerEvents(pool, 'exit', numberOfThreads)