coolaj86
/
batchasync.js
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

make Prettier

This commit is contained in:
AJ ONeal 2019-11-25 15:43:58 -07:00
parent dd206891d5
commit 9beae76631
1 changed files with 105 additions and 105 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

210
test.js
View File

@ -1,110 +1,110 @@
(function (exports) { (function(exports) {
'use strict'; "use strict";
var batchAsync = exports.batchAsync || require('./batchasync.js').batchAsync; var batchAsync =
exports.batchAsync || require("./batchasync.js").batchAsync;
function testBatch() { function testBatch() {
var timeouts = [100, 80, 20, 500, 50, 30, 200, 300]; var timeouts = [100, 80, 20, 500, 50, 30, 200, 300];
var tasks = timeouts.map(function(timeout, i) { var tasks = timeouts.map(function(timeout, i) {
return function() { return function() {
return promiseTimeout(timeout).then(function() { return promiseTimeout(timeout).then(function() {
console.log('task:', i, timeouts[i]); console.log("task:", i, timeouts[i]);
return i; return i;
}); });
}; };
}); });
var len = tasks.length; var len = tasks.length;
return batchAsync(4, tasks, function(task) { return batchAsync(4, tasks, function(task) {
return task(); return task();
}) })
.then(function(results) { .then(function(results) {
console.info('results:', results); console.info("results:", results);
if (len !== results.length) { if (len !== results.length) {
throw new Error('result set too small'); throw new Error("result set too small");
} }
if (results.join(' ') !== results.sort().join(' ')) { if (results.join(" ") !== results.sort().join(" ")) {
throw new Error('result set out-of-order'); throw new Error("result set out-of-order");
} }
}) })
.then(function() { .then(function() {
return batchAsync(4, [], 'not a function').then(function() { return batchAsync(4, [], "not a function").then(function() {
console.info('Handled ZERO tasks correctly.'); console.info("Handled ZERO tasks correctly.");
}); });
}) })
.then(function() { .then(function() {
return batchAsync(4, timeouts, function(x) { return batchAsync(4, timeouts, function(x) {
return x; return x;
}).then(function(results) { }).then(function(results) {
if (results.join(' ') !== timeouts.join(' ')) { if (results.join(" ") !== timeouts.join(" ")) {
console.error(results); console.error(results);
throw new Error('sync result set out-of-order'); throw new Error("sync result set out-of-order");
} }
console.info('Handled sync tasks correctly.'); console.info("Handled sync tasks correctly.");
}); });
}) })
.then(function() { .then(function() {
return batchAsync(4, tasks, function(task) { return batchAsync(4, tasks, function(task) {
if (0 === Math.floor(Math.random() * 2) % 2) { if (0 === Math.floor(Math.random() * 2) % 2) {
throw new Error('any async error will do'); throw new Error("any async error will do");
} }
return task(); return task();
}) })
.then(function(results) { .then(function(results) {
console.log(results); console.log(results);
var e = new Error('async rejection should not pass!'); var e = new Error("async rejection should not pass!");
e.FAIL = true; e.FAIL = true;
throw e; throw e;
}) })
.catch(function(e) { .catch(function(e) {
if (e.FAIL) { if (e.FAIL) {
throw e; throw e;
} }
console.info('Pass: Exception thrown when expected'); console.info("Pass: Exception thrown when expected");
}); });
}) })
.then(function() { .then(function() {
return batchAsync(4, timeouts, function() { return batchAsync(4, timeouts, function() {
if (0 === Math.floor(Math.random() * 2) % 2) { if (0 === Math.floor(Math.random() * 2) % 2) {
throw new Error('any sync error will do'); throw new Error("any sync error will do");
} }
return null; return null;
}) })
.then(function(results) { .then(function(results) {
var e = new Error('should not pass sync exception!'); var e = new Error("should not pass sync exception!");
e.FAIL = true; e.FAIL = true;
throw e; throw e;
}) })
.catch(function(e) { .catch(function(e) {
if (e.FAIL) { if (e.FAIL) {
throw e; throw e;
} }
}) })
.then(function() { .then(function() {
// wait for the tasks the error left dangling to print their message // wait for the tasks the error left dangling to print their message
console.info('Pass: Promise rejected when expected'); console.info("Pass: Promise rejected when expected");
return promiseTimeout(1000); return promiseTimeout(1000);
}); });
}); });
} }
function promiseTimeout(timeout) { function promiseTimeout(timeout) {
return new Promise(function(resolve, reject) { return new Promise(function(resolve, reject) {
setTimeout(resolve, timeout); setTimeout(resolve, timeout);
}); });
} }
testBatch() testBatch()
.then(function() { .then(function() {
console.info('PROBABLY PASSED'); console.info("PROBABLY PASSED");
console.info( console.info(
'We tested what could be tested without knowing Passed what could be tested Do the results make sense?' "We tested what could be tested without knowing Passed what could be tested Do the results make sense?"
); );
}) })
.catch(function(e) { .catch(function(e) {
console.error('FAIL!'); console.error("FAIL!");
console.error(e); console.error(e);
process.exit(500); process.exit(500);
}); });
})("undefined" !== typeof window ? window : module.exports);
}('undefined' !== typeof window ? window : module.exports));