tests/worker/cluster/longRunningWorker.js

   1 'use strict'
   2 const { ClusterWorker } = require('../../../lib/index')
   3
   4 async function sleep (data) {
   5   return new Promise((resolve, reject) => {
   6     setTimeout(() => resolve(data), 50000)
   7   })
   8 }
   9
  10 module.exports = new ClusterWorker(sleep, { maxInactiveTime: 500, async: true })