Bugfix: sending saturated event should respect current concurrency.

2 files changed, 3 insertions, 2 deletions

diff --git a/lib/async.js b/lib/async.js
index 04f7246..312e645 100755
--- a/lib/async.js
+++ b/lib/async.js
@@ -709,7 +709,7 @@
                 q.tasks.push(item);
               }
 
-              if (q.saturated && q.tasks.length === concurrency) {
+              if (q.saturated && q.tasks.length === q.concurrency) {
                   q.saturated();
               }
               async.setImmediate(q.process);
diff --git a/test/test-async.js b/test/test-async.js
index fdcac5f..518650f 100755
--- a/test/test-async.js
+++ b/test/test-async.js
@@ -2664,7 +2664,8 @@ exports['queue events'] = function(test) {
         // nop
         calls.push('process ' + task);
         async.setImmediate(cb);
-    }, 3);
+    }, 10);
+    q.concurrency = 3;
 
     q.saturated = function() {
         test.ok(q.length() == 3, 'queue should be saturated now');