[poolifier.git] / tests / test-utils.js

class TestUtils {
  static async waitExits (pool, numberOfExitEventsToWait) {
    let exitEvents = 0
    return new Promise(function (resolve, reject) {
      pool.workers.forEach(w => {
        w.on('exit', () => {
          exitEvents++
          if (exitEvents === numberOfExitEventsToWait) {
            resolve(exitEvents)
          }
        })
      })
    })
  }

  static async sleep (ms) {
    return new Promise(resolve => setTimeout(resolve, ms))
  }
}

module.exports = TestUtils
Commit	Line	Data
	1	class TestUtils {
	2	static async waitExits (pool, numberOfExitEventsToWait) {
	3	let exitEvents = 0
	4	return new Promise(function (resolve, reject) {
	5	pool.workers.forEach(w => {
	6	w.on('exit', () => {
	7	exitEvents++
	8	if (exitEvents === numberOfExitEventsToWait) {
	9	resolve(exitEvents)
	10	}
	11	})
	12	})
	13	})
	14	}
	15
	16	static async sleep (ms) {
	17	return new Promise(resolve => setTimeout(resolve, ms))
	18	}
	19	}
	20
	21	module.exports = TestUtils