X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fworker-files%2Fthread%2FasyncErrorWorker.js;h=f696b101947d6dc7ed180feae6fe7a0f763797b6;hb=b4c2a50df77a5f3110d228436ce9f3008cbd8297;hp=d973f0a4d7625e826c19ad550c1f61a6f7836217;hpb=7c0ba92006a5c188738ffc5ff642c51f172df3d6;p=poolifier.git diff --git a/tests/worker-files/thread/asyncErrorWorker.js b/tests/worker-files/thread/asyncErrorWorker.js index d973f0a4..f696b101 100644 --- a/tests/worker-files/thread/asyncErrorWorker.js +++ b/tests/worker-files/thread/asyncErrorWorker.js @@ -1,14 +1,17 @@ 'use strict' -const { ThreadWorker, KillBehaviors } = require('../../../lib/index') +const { ThreadWorker, KillBehaviors } = require('../../../lib') +const { sleepTaskFunction } = require('../../test-utils') async function error (data) { - return new Promise((resolve, reject) => { - setTimeout(() => reject(new Error(data)), 2000) - }) + return sleepTaskFunction( + data, + 2000, + true, + 'Error Message from ThreadWorker:async' + ) } module.exports = new ThreadWorker(error, { - maxInactiveTime: 500, - async: true, - killBehavior: KillBehaviors.HARD + killBehavior: KillBehaviors.HARD, + maxInactiveTime: 500 })