X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=tests%2Fworker-files%2Fcluster%2FasyncErrorWorker.js;h=028a7cf3a77a97689442576fb40d6457c623df8c;hb=1c881a974a7849061a4e508885b5a96bdc134194;hp=2476853b55520ab5fea4c917fb70d0f05c66dfa0;hpb=b8818d59f9e410ce2e3b0103b8372b3fa1badf8f;p=poolifier.git diff --git a/tests/worker-files/cluster/asyncErrorWorker.js b/tests/worker-files/cluster/asyncErrorWorker.js index 2476853b..028a7cf3 100644 --- a/tests/worker-files/cluster/asyncErrorWorker.js +++ b/tests/worker-files/cluster/asyncErrorWorker.js @@ -1,16 +1,17 @@ 'use strict' -const { ClusterWorker } = require('../../../lib/index') +const { ClusterWorker, KillBehaviors } = require('../../../lib') +const { sleepTaskFunction } = require('../../test-utils') async function error (data) { - return new Promise((resolve, reject) => { - setTimeout( - () => reject(new Error('Error Message from ClusterWorker:async')), - 2000 - ) - }) + return sleepTaskFunction( + data, + 2000, + true, + 'Error Message from ClusterWorker:async' + ) } module.exports = new ClusterWorker(error, { maxInactiveTime: 500, - async: true + killBehavior: KillBehaviors.HARD })