From e24631da681c172ceae3afd33f58909ad0e10ba9 Mon Sep 17 00:00:00 2001 From: "Alex A. Naanou" Date: Sat, 7 Nov 2020 04:06:35 +0300 Subject: [PATCH] addad taskStarting event... Signed-off-by: Alex A. Naanou --- runner.js | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/runner.js b/runner.js index 32a3270..4a73990 100644 --- a/runner.js +++ b/runner.js @@ -89,6 +89,8 @@ module.Queue = object.Constructor('Queue', Array, { return this }, // events... + taskStarting: makeEvent(function(func){ + return this.on('taskStarting', ...arguments) }), taskCompleted: makeEvent(function(func){ return this.on('taskCompleted', ...arguments) }), @@ -109,8 +111,10 @@ module.Queue = object.Constructor('Queue', Array, { && this.state == 'running' && running.length < (this.pool_size || Infinity) ){ - // run... var task = this.shift() + this.trigger('taskStarting', task) + + // run... var res = typeof(task) == 'function' ? task() : task