diff options
-rwxr-xr-x | test/test-async.js | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/test/test-async.js b/test/test-async.js index fe927de..108d8b8 100755 --- a/test/test-async.js +++ b/test/test-async.js @@ -3391,6 +3391,25 @@ exports['queue empty'] = function(test) { q.push([]); }; +exports['queue saturated'] = function (test) { + var saturatedCalled = false; + var q = async.queue(function(task, cb) { + async.setImmediate(cb); + }, 2); + + q.saturated = function () { + saturatedCalled = true; + }; + q.drain = function () { + test.ok(saturatedCalled, "saturated not called"); + test.done(); + }; + + setTimeout(function () { + q.push(['foo', 'bar', 'baz', 'moo']); + }, 10); +}; + exports['queue started'] = function(test) { var calls = []; |