} = require('../../../lib')
const { CircularArray } = require('../../../lib/circular-array')
const { Deque } = require('../../../lib/deque')
+const { DEFAULT_TASK_NAME } = require('../../../lib/utils')
const { version } = require('../../../package.json')
const { waitPoolEvents } = require('../../test-utils')
)
await waitPoolEvents(dynamicThreadPool, PoolEvents.ready, 1)
expect(dynamicThreadPool.listTaskFunctions()).toStrictEqual([
- 'default',
+ DEFAULT_TASK_NAME,
'jsonIntegerSerialization',
'factorial',
'fibonacci'
)
await waitPoolEvents(fixedClusterPool, PoolEvents.ready, 1)
expect(fixedClusterPool.listTaskFunctions()).toStrictEqual([
- 'default',
+ DEFAULT_TASK_NAME,
'jsonIntegerSerialization',
'factorial',
'fibonacci'
])
+ await dynamicThreadPool.destroy()
+ await fixedClusterPool.destroy()
})
it('Verify that multiple task functions worker is working', async () => {
expect(pool.info.executedTasks).toBe(4)
for (const workerNode of pool.workerNodes) {
expect(workerNode.info.taskFunctions).toStrictEqual([
- 'default',
+ DEFAULT_TASK_NAME,
'jsonIntegerSerialization',
'factorial',
'fibonacci'
).toBeGreaterThanOrEqual(0)
}
}
+ await pool.destroy()
})
})