-class TestUtils {
- static async waitWorkerExits (pool, numberOfExitEventsToWait) {
- return new Promise(resolve => {
- let exitEvents = 0
- if (numberOfExitEventsToWait === 0) {
- resolve(exitEvents)
- }
- for (const workerNode of pool.workerNodes) {
- workerNode.worker.on('exit', () => {
- ++exitEvents
- if (exitEvents === numberOfExitEventsToWait) {
- resolve(exitEvents)
- }
- })
- }
- })
- }
-
- static async waitPoolEvents (pool, poolEvent, numberOfEventsToWait) {
- return new Promise(resolve => {
- let events = 0
- if (numberOfEventsToWait === 0) {
- resolve(events)
- }
- pool.emitter.on(poolEvent, () => {
+const waitWorkerEvents = async (pool, workerEvent, numberOfEventsToWait) => {
+ return await new Promise(resolve => {
+ let events = 0
+ if (numberOfEventsToWait === 0) {
+ resolve(events)
+ }
+ for (const workerNode of pool.workerNodes) {
+ workerNode.worker.on(workerEvent, () => {