-const { EventEmitter } = require('node:events')
+const { EventEmitterAsyncResource } = require('node:events')
const { expect } = require('expect')
const sinon = require('sinon')
const {
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
- expect(pool.emitter).toBeInstanceOf(EventEmitter)
+ expect(pool.emitter).toBeInstanceOf(EventEmitterAsyncResource)
expect(pool.opts).toStrictEqual({
startWorkers: true,
enableEvents: true,
numberOfWorkers,
'./tests/worker-files/cluster/testWorker.js'
)
+ expect(pool.emitter.eventNames()).toStrictEqual([])
let poolInfo
let poolReady = 0
pool.emitter.on(PoolEvents.ready, info => {
poolInfo = info
})
await waitPoolEvents(pool, PoolEvents.ready, 1)
+ expect(pool.emitter.eventNames()).toStrictEqual([PoolEvents.ready])
expect(poolReady).toBe(1)
expect(poolInfo).toStrictEqual({
version,
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
+ expect(pool.emitter.eventNames()).toStrictEqual([])
const promises = new Set()
let poolBusy = 0
let poolInfo
++poolBusy
poolInfo = info
})
+ expect(pool.emitter.eventNames()).toStrictEqual([PoolEvents.busy])
for (let i = 0; i < numberOfWorkers * 2; i++) {
promises.add(pool.execute())
}
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
+ expect(pool.emitter.eventNames()).toStrictEqual([])
const promises = new Set()
let poolFull = 0
let poolInfo
++poolFull
poolInfo = info
})
+ expect(pool.emitter.eventNames()).toStrictEqual([PoolEvents.full])
for (let i = 0; i < numberOfWorkers * 2; i++) {
promises.add(pool.execute())
}
}
)
sinon.stub(pool, 'hasBackPressure').returns(true)
+ expect(pool.emitter.eventNames()).toStrictEqual([])
const promises = new Set()
let poolBackPressure = 0
let poolInfo
++poolBackPressure
poolInfo = info
})
+ expect(pool.emitter.eventNames()).toStrictEqual([PoolEvents.backPressure])
for (let i = 0; i < numberOfWorkers + 1; i++) {
promises.add(pool.execute())
}