From 971f97e5f5985d58614fd3dbcca583dba250e964 Mon Sep 17 00:00:00 2001 From: "Harish.K" Date: Fri, 12 Sep 2014 21:45:38 +0530 Subject: [PATCH] Fix: Don't call onStopped immediatly on stop(). Instead call onStopped() after finishing all running tasks --- src/JobManager.js | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/JobManager.js b/src/JobManager.js index a610a6a..872ce9c 100644 --- a/src/JobManager.js +++ b/src/JobManager.js @@ -90,6 +90,9 @@ JobManager.prototype.$doWork_ = function( cb ){ } } cb(); + if( self.state == STATE.NOT_RUNNING ){ + if( ( self.runningTasks == 1 ) && self.onStopped ) { self.onStopped(); } + } self.returnToPool( worker ); }); }; @@ -124,7 +127,6 @@ JobManager.prototype.pause = function(){ JobManager.prototype.stop = function(){ this.state = STATE.NOT_RUNNING; - if( this.onStopped ){ this.onStopped(); } };