diff options
Diffstat (limited to 'lib/async.js')
-rwxr-xr-x | lib/async.js | 8 |
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, |