batchasync.js

@@ -1,5 +1,5 @@
 (function (exports) {
-    "use strict";
+'use strict';
 
 exports.batchAsync = function (limit, arr, doStuff) {
 	arr = arr.slice(0);
@@ -37,7 +37,7 @@
 
 			var p;
 			try {
-                    p = doStuff(task, index, arr);
+				p = doStuff(task);
 			} catch (e) {
 				// we need to handle, and bubble, synchronous errors
 				error = e;
@@ -48,7 +48,7 @@
 			// add support for sync by rapping in a promise
 			Promise.resolve(p)
 				.then(function(result) {
-                        if ("undefined" === typeof result) {
+					if ('undefined' === typeof result) {
 						throw new Error(
 							"result was 'undefined'. Please return 'null' to signal that you didn't just forget to return another promise."
 						);
@@ -67,4 +67,5 @@
 		doMoreStuff();
 	});
 };
-})("undefined" !== typeof window ? window : module.exports);
+
+}('undefined' !== typeof window ? window : module.exports));

package-lock.json

@@ -1,5 +0,0 @@
-{
-  "name": "batchasync",
-  "version": "1.0.3",
-  "lockfileVersion": 1
-}

package.json

@@ -1,6 +1,6 @@
 {
   "name": "batchasync",
-  "version": "1.0.3",
+  "version": "1.0.2",
   "description": "Like forEachAsync, or Promise.all(), but handling a bounded number of items at any given time.",
   "main": "batchasync.js",
   "scripts": {

test.js

@@ -1,17 +1,15 @@
 (function (exports) {
-    "use strict";
+'use strict';
 
-    var batchAsync =
-        exports.batchAsync || require("./batchasync.js").batchAsync;
+var batchAsync = exports.batchAsync || require('./batchasync.js').batchAsync;
 
 function testBatch() {
 	var timeouts = [100, 80, 20, 500, 50, 30, 200, 300];
-        console.info(timeouts);
 	var tasks = timeouts.map(function(timeout, i) {
 		return function() {
 			return promiseTimeout(timeout).then(function() {
-                    //console.log("task:", i, timeouts[i]);
-                    return i + ":" + timeouts[i];
+				console.log('task:', i, timeouts[i]);
+				return i;
 			});
 		};
 	});
@@ -21,40 +19,40 @@
 		return task();
 	})
 		.then(function(results) {
-                console.info("results:", results);
+			console.info('results:', results);
 			if (len !== results.length) {
-                    throw new Error("result set too small");
+				throw new Error('result set too small');
 			}
-                if (results.join(" ") !== results.sort().join(" ")) {
-                    throw new Error("result set out-of-order");
+			if (results.join(' ') !== results.sort().join(' ')) {
+				throw new Error('result set out-of-order');
 			}
 		})
 		.then(function() {
-                return batchAsync(4, [], "not a function").then(function() {
-                    console.info("Handled ZERO tasks correctly.");
+			return batchAsync(4, [], 'not a function').then(function() {
+				console.info('Handled ZERO tasks correctly.');
 			});
 		})
 		.then(function() {
 			return batchAsync(4, timeouts, function(x) {
 				return x;
 			}).then(function(results) {
-                    if (results.join(" ") !== timeouts.join(" ")) {
+				if (results.join(' ') !== timeouts.join(' ')) {
 					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() {
 			return batchAsync(4, tasks, function(task) {
 				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();
 			})
 				.then(function(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;
 					throw e;
 				})
@@ -62,18 +60,18 @@
 					if (e.FAIL) {
 						throw e;
 					}
-                        console.info("Pass: Exception thrown when expected");
+					console.info('Pass: Exception thrown when expected');
 				});
 		})
 		.then(function() {
 			return batchAsync(4, timeouts, function() {
 				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;
 			})
-                    .then(function(/*results*/) {
-                        var e = new Error("should not pass sync exception!");
+				.then(function(results) {
+					var e = new Error('should not pass sync exception!');
 					e.FAIL = true;
 					throw e;
 				})
@@ -84,28 +82,29 @@
 				})
 				.then(function() {
 					// 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);
 				});
 		});
 }
 
 function promiseTimeout(timeout) {
-        return new Promise(function(resolve) {
+	return new Promise(function(resolve, reject) {
 		setTimeout(resolve, timeout);
 	});
 }
 
 testBatch()
 	.then(function() {
-            console.info("PROBABLY PASSED");
+		console.info('PROBABLY PASSED');
 		console.info(
-                "We tested 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) {
-            console.error("FAIL!");
+		console.error('FAIL!');
 		console.error(e);
     process.exit(500);
 	});
-})("undefined" !== typeof window ? window : module.exports);
+
+}('undefined' !== typeof window ? window : module.exports));