From c2b098bb46c9c17bb901a91073dae461dfad7ca8 Mon Sep 17 00:00:00 2001 From: Teemu Ikonen Date: Sat, 11 Jan 2014 12:17:39 +0800 Subject: Queue calls drain if empty task list is pushed --- lib/async.js | 8 ++++++++ 1 file changed, 8 insertions(+) (limited to 'lib') diff --git a/lib/async.js b/lib/async.js index cb6320d..7a4361f 100755 --- a/lib/async.js +++ b/lib/async.js @@ -675,6 +675,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, -- cgit v1.2.1