task-queue - npm Package Compare versions

Comparing version 1.0.1 to 1.0.2

lib/tq.js

@@ -53,13 +53,24 @@ // Generated by CoffeeScript 1.8.0
               return function() {
-                var _ref, _ref1;
-                deq.method.apply((_ref = deq.context) != null ? _ref : null, (_ref1 = deq.args) != null ? _ref1 : null);
+                var task_return, _ref, _ref1;
+                task_return = deq.method.apply((_ref = deq.context) != null ? _ref : null, (_ref1 = deq.args) != null ? _ref1 : null);
+                if (_this.finishedTask != null) {
+                  setImmediate(function() {
+                    return _this.finishedTask(task_return);
+                  });
+                }
                 if (--actual_concurrency === 0) {
-                  if (_this._singleShot && _this.size() === 0) {
-                    _this._singleShot = false;
-                    _this._running = false;
+                  if (_this.size() === 0) {
+                    if (_this.finished != null) {
+                      setImmediate(function() {
+                        return _this.finished();
+                      });
+                    }
+                    if (_this._singleShot && _this.size() === 0) {
+                      _this._singleShot = false;
+                      _this._running = false;
+                    }
                   }
-                  _this._exec;
-                  if (_this.finished != null) {
-                    return setTimeout(_this.finished, _this.opts.timeout);
-                  }
+                  return setTimeout((function() {
+                    return _this._exec();
+                  }), _this.opts.timeout);
                 }
@@ -66,0 +77,0 @@ };

package.json

 {
     "author" : "Roberto Sales <[e-mail]>",
     "name": "task-queue",
-    "version": "1.0.1",
+    "version": "1.0.2",
     "description": "async single worker tasks queue that supports concurrency, priority and provide simple interface for passing task arguments",
@@ -12,3 +12,3 @@ "keywords": ["task", "queue", "worker", "concurrency", "async", "priority"],
         "type": "git",
-        "url": "http://github.com/skywalkerd/task-queue.git"
+        "url": "http://github.com/rsalesc/task-queue.git"
     },
@@ -15,0 +15,0 @@ "dependencies":

No alert changes

Improved metrics

Total package byte prevSize

54421

11.53%

Lines of code

286

4%

Number of lines in readme file

87

8600%

No dependency changes