summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexander Early <aearly@fluid.com>2015-05-31 00:09:45 -0700
committerAlexander Early <aearly@fluid.com>2015-05-31 00:09:45 -0700
commitf601150113224452d9f5c4c10ab4c7f5be9f85dd (patch)
treec747892be0b7fd7fad7ffe6e92c5d1147401e63c
parent1f3069066ef584523258d5d8360a1cea6d59ba4c (diff)
downloadasync-f601150113224452d9f5c4c10ab4c7f5be9f85dd.tar.gz
reorganized more tests
-rwxr-xr-xtest/test-async.js104
1 files changed, 60 insertions, 44 deletions
diff --git a/test/test-async.js b/test/test-async.js
index 747bb93..b0be295 100755
--- a/test/test-async.js
+++ b/test/test-async.js
@@ -2638,7 +2638,7 @@ exports['queue'] = {
};
},
-'queue default concurrency': function (test) {
+'default concurrency': function (test) {
var call_order = [],
delays = [160,80,240,80];
@@ -2691,7 +2691,7 @@ exports['queue'] = {
};
},
-'queue zero concurrency': function(test){
+'zero concurrency': function(test){
test.throws(function () {
async.queue(function (task, callback) {
callback(null, task);
@@ -2700,7 +2700,7 @@ exports['queue'] = {
test.done();
},
-'queue error propagation': function(test){
+'error propagation': function(test){
var results = [];
var q = async.queue(function (task, callback) {
@@ -2731,7 +2731,7 @@ exports['queue'] = {
});
},
-'queue changing concurrency': function (test) {
+'changing concurrency': function (test) {
var call_order = [],
delays = [40,20,60,20];
@@ -2786,7 +2786,7 @@ exports['queue'] = {
}, 250);
},
-'queue push without callback': function (test) {
+'push without callback': function (test) {
var call_order = [],
delays = [160,80,240,80];
@@ -2817,7 +2817,7 @@ exports['queue'] = {
}, 800);
},
-'queue unshift': function (test) {
+'unshift': function (test) {
var queue_order = [];
var q = async.queue(function (task, callback) {
@@ -2836,7 +2836,7 @@ exports['queue'] = {
}, 100);
},
-'queue too many callbacks': function (test) {
+'too many callbacks': function (test) {
var q = async.queue(function (task, callback) {
callback();
test.throws(function() {
@@ -2848,7 +2848,7 @@ exports['queue'] = {
q.push(1);
},
-'queue bulk task': function (test) {
+'bulk task': function (test) {
var call_order = [],
delays = [160,80,240,80];
@@ -2884,7 +2884,7 @@ exports['queue'] = {
}, 800);
},
-'queue idle': function(test) {
+'idle': function(test) {
var q = async.queue(function (task, callback) {
// Queue is busy when workers are running
test.equal(q.idle(), false);
@@ -2909,7 +2909,7 @@ exports['queue'] = {
};
},
-'queue pause': function(test) {
+'pause': function(test) {
var call_order = [],
task_timeout = 100,
pause_timeout = 300,
@@ -2962,7 +2962,7 @@ exports['queue'] = {
}, 800);
},
-'queue pause with concurrency': function(test) {
+'pause with concurrency': function(test) {
var call_order = [],
task_timeout = 100,
pause_timeout = 50,
@@ -3013,7 +3013,7 @@ exports['queue'] = {
}, 800);
},
-'queue start paused': function (test) {
+'start paused': function (test) {
var q = async.queue(function (task, callback) {
setTimeout(function () {
callback();
@@ -3037,7 +3037,7 @@ exports['queue'] = {
};
},
-'queue kill': function (test) {
+'kill': function (test) {
var q = async.queue(function (task, callback) {
setTimeout(function () {
test.ok(false, "Function should never be called");
@@ -3058,7 +3058,7 @@ exports['queue'] = {
}, 600);
},
-'queue events': function(test) {
+'events': function(test) {
var calls = [];
var q = async.queue(function(task, cb) {
// nop
@@ -3105,7 +3105,7 @@ exports['queue'] = {
q.push('moo', function () {calls.push('moo cb');});
},
-'queue empty': function(test) {
+'empty': function(test) {
var calls = [];
var q = async.queue(function(task, cb) {
// nop
@@ -3127,7 +3127,7 @@ exports['queue'] = {
q.push([]);
},
-'queue saturated': function (test) {
+'saturated': function (test) {
var saturatedCalled = false;
var q = async.queue(function(task, cb) {
async.setImmediate(cb);
@@ -3146,7 +3146,7 @@ exports['queue'] = {
}, 10);
},
-'queue started': function(test) {
+'started': function(test) {
var q = async.queue(function(task, cb) {
cb(null, task);
@@ -3161,7 +3161,10 @@ exports['queue'] = {
};
-exports['priorityQueue'] = function (test) {
+
+exports['priorityQueue'] = {
+
+'priorityQueue': function (test) {
var call_order = [];
// order of completion: 2,1,4,3
@@ -3209,9 +3212,9 @@ exports['priorityQueue'] = function (test) {
test.equal(q.length(), 0);
test.done();
};
-};
+},
-exports['priorityQueue concurrency'] = function (test) {
+' concurrency': function (test) {
var call_order = [],
delays = [160,80,240,80];
@@ -3264,9 +3267,14 @@ exports['priorityQueue concurrency'] = function (test) {
test.equal(q.length(), 0);
test.done();
};
+}
+
};
-exports['cargo'] = function (test) {
+
+exports['cargo'] = {
+
+'cargo': function (test) {
var call_order = [],
delays = [160, 160, 80];
@@ -3330,9 +3338,9 @@ exports['cargo'] = function (test) {
test.equal(c.length(), 0);
test.done();
}, 800);
-};
+},
-exports['cargo without callback'] = function (test) {
+'without callback': function (test) {
var call_order = [],
delays = [160,80,240,80];
@@ -3366,9 +3374,9 @@ exports['cargo without callback'] = function (test) {
]);
test.done();
}, 800);
-};
+},
-exports['cargo bulk task'] = function (test) {
+'bulk task': function (test) {
var call_order = [],
delays = [120,40];
@@ -3398,9 +3406,9 @@ exports['cargo bulk task'] = function (test) {
test.equal(c.length(), 0);
test.done();
}, 800);
-};
+},
-exports['cargo drain once'] = function (test) {
+'drain once': function (test) {
var c = async.cargo(function (tasks, callback) {
callback();
@@ -3419,9 +3427,9 @@ exports['cargo drain once'] = function (test) {
test.equal(drainCounter, 1);
test.done();
}, 500);
-};
+},
-exports['cargo drain twice'] = function (test) {
+'drain twice': function (test) {
var c = async.cargo(function (tasks, callback) {
callback();
@@ -3445,9 +3453,15 @@ exports['cargo drain twice'] = function (test) {
test.equal(drainCounter, 2);
test.done();
}, 1000);
+}
+
};
-exports['memoize'] = function (test) {
+
+
+exports['memoize'] = {
+
+'memoize': function (test) {
test.expect(5);
var call_order = [];
@@ -3471,9 +3485,9 @@ exports['memoize'] = function (test) {
});
});
});
-};
+},
-exports['memoize maintains asynchrony'] = function (test) {
+'maintains asynchrony': function (test) {
test.expect(3);
var call_order = [];
@@ -3510,9 +3524,9 @@ exports['memoize maintains asynchrony'] = function (test) {
test.same(call_order, async_call_order);
test.done();
}
-};
+},
-exports['unmemoize'] = function(test) {
+'unmemoize': function(test) {
test.expect(4);
var call_order = [];
@@ -3536,9 +3550,9 @@ exports['unmemoize'] = function(test) {
});
});
});
-};
+},
-exports['unmemoize a not memoized function'] = function(test) {
+'unmemoize a not memoized function': function(test) {
test.expect(1);
var fn = function (arg1, arg2, callback) {
@@ -3551,9 +3565,9 @@ exports['unmemoize a not memoized function'] = function(test) {
});
test.done();
-};
+},
-exports['memoize error'] = function (test) {
+'error': function (test) {
test.expect(1);
var testerr = new Error('test');
var fn = function (arg1, arg2, callback) {
@@ -3563,9 +3577,9 @@ exports['memoize error'] = function (test) {
test.equal(err, testerr);
});
test.done();
-};
+},
-exports['memoize multiple calls'] = function (test) {
+'multiple calls': function (test) {
test.expect(3);
var fn = function (arg1, arg2, callback) {
test.ok(true);
@@ -3581,9 +3595,9 @@ exports['memoize multiple calls'] = function (test) {
test.equal(result, 1, 2);
test.done();
});
-};
+},
-exports['memoize custom hash function'] = function (test) {
+'custom hash function': function (test) {
test.expect(2);
var testerr = new Error('test');
@@ -3600,9 +3614,9 @@ exports['memoize custom hash function'] = function (test) {
test.done();
});
});
-};
+},
-exports['memoize manually added memo value'] = function (test) {
+'manually added memo value': function (test) {
test.expect(1);
var fn = async.memoize(function() {
test(false, "Function should never be called");
@@ -3612,6 +3626,8 @@ exports['memoize manually added memo value'] = function (test) {
test.equal(val, "bar");
test.done();
});
+}
+
};