-const { TaskFunctions } = require('./test-types')
+const { TaskFunctions } = require('./test-types.js')
const waitWorkerEvents = async (pool, workerEvent, numberOfEventsToWait) => {
return await new Promise(resolve => {
let events = 0
if (numberOfEventsToWait === 0) {
resolve(events)
+ return
}
for (const workerNode of pool.workerNodes) {
workerNode.worker.on(workerEvent, () => {
let events = 0
if (numberOfEventsToWait === 0) {
resolve(events)
+ return
}
pool.emitter?.on(poolEvent, () => {
++events