added tests for #508 and #512

caolan · May 21, 2015 · 651232e · 651232e
1 parent e968c02
commit 651232e
Showing 1 changed file with 28 additions and 0 deletions.
diff --git a/test/test-async.js b/test/test-async.js
@@ -2790,6 +2790,10 @@ exports['queue pause with concurrency'] = function(test) {
         test.equal(q.paused, false);
     }, resume_timeout);
 
+    setTimeout(function () {
+        test.equal(q.running(), 2);
+    }, resume_timeout + 10);
+
     setTimeout(function () {
         test.same(call_order, [
             'process 1', 'timeout 100',
@@ -2803,6 +2807,30 @@ exports['queue pause with concurrency'] = function(test) {
     }, 800);
 };
 
+exports['queue start paused'] = function (test) {
+    var q = async.queue(function (task, callback) {
+        setTimeout(function () {
+            callback();
+        }, 10);
+    }, 2);
+    q.pause();
+
+    q.push([1, 2, 3]);
+
+    setTimeout(function () {
+        q.resume();
+    }, 10);
+
+    setTimeout(function () {
+        test.equal(q.running(), 2);
+        q.resume();
+    }, 15);
+
+    q.drain = function () {
+        test.done();
+    };
+};
+
 exports['queue kill'] = function (test) {
     var q = async.queue(function (task, callback) {
         setTimeout(function () {