- it('Shutdown test', async () => {
- let closedWorkers = 0
- pool.workers.forEach(w => {
- w.on('exit', () => {
- closedWorkers++
- })
- })
- pool.destroy()
- await new Promise(resolve => setTimeout(resolve, 2000))
- expect(closedWorkers).toBe(min)
- })