Method wrapForegroundJob

dadi/lib/workQueue.js:64–82

(wrappedFunction)

  }

  wrapForegroundJob(wrappedFunction) {
    const context = this

    return function() {
      const jobId = context.startForegroundJob()

      return Promise.resolve(wrappedFunction.apply(this, arguments))
        .then(result => {
          context.finishForegroundJob(jobId)

          return result
        })
        .catch(error => {
          context.finishForegroundJob(jobId)

          return Promise.reject(error)
        })
    }
  }
}

module.exports = new WorkQueue()