Merge pull request #433 from tikonen/master

Queue calls drain if empty task list is pushed

1 files changed, 8 insertions, 0 deletions

diff --git a/lib/async.js b/lib/async.js
index c6ac74e..16240f8 100755
--- a/lib/async.js
+++ b/lib/async.js
@@ -678,6 +678,14 @@
           if(data.constructor !== Array) {
               data = [data];
           }
+          if(data.length == 0) {
+             // call drain immediately if there are no tasks
+             return async.setImmediate(function() {
+                 if (q.drain) {
+                     q.drain();
+                 }
+             });
+          }
           _each(data, function(task) {
               var item = {
                   data: task,