const { expect } = require('expect')
const { DynamicClusterPool, PoolEvents } = require('../../../lib')
const { expect } = require('expect')
const { DynamicClusterPool, PoolEvents } = require('../../../lib')
const { sleep, waitWorkerEvents } = require('../../test-utils')
describe('Dynamic cluster pool test suite', () => {
const { sleep, waitWorkerEvents } = require('../../test-utils')
describe('Dynamic cluster pool test suite', () => {
}
)
it('Verify that the function is executed in a worker cluster', async () => {
let result = await pool.execute({
}
)
it('Verify that the function is executed in a worker cluster', async () => {
let result = await pool.execute({
it('Shutdown test', async () => {
const exitPromise = waitWorkerEvents(pool, 'exit', min)
it('Shutdown test', async () => {
const exitPromise = waitWorkerEvents(pool, 'exit', min)
onlineHandler: () => console.info('long executing worker is online'),
exitHandler: () => console.info('long executing worker exited')
}
onlineHandler: () => console.info('long executing worker is online'),
exitHandler: () => console.info('long executing worker exited')
}
onlineHandler: () => console.info('long executing worker is online'),
exitHandler: () => console.info('long executing worker exited')
}
onlineHandler: () => console.info('long executing worker is online'),
exitHandler: () => console.info('long executing worker exited')
}