diff --git a/batchasync.js b/batchasync.js index f031136..e455c18 100644 --- a/batchasync.js +++ b/batchasync.js @@ -37,7 +37,7 @@ var p; try { - p = doStuff(task); + p = doStuff(task, index, arr); } catch (e) { // we need to handle, and bubble, synchronous errors error = e; diff --git a/package-lock.json b/package-lock.json new file mode 100644 index 0000000..cebfebc --- /dev/null +++ b/package-lock.json @@ -0,0 +1,5 @@ +{ + "name": "batchasync", + "version": "1.0.3", + "lockfileVersion": 1 +} diff --git a/package.json b/package.json index 7dfc293..7f3dd7a 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "batchasync", - "version": "1.0.2", + "version": "1.0.3", "description": "Like forEachAsync, or Promise.all(), but handling a bounded number of items at any given time.", "main": "batchasync.js", "scripts": { diff --git a/test.js b/test.js index fc1e6d8..bbeca08 100644 --- a/test.js +++ b/test.js @@ -6,11 +6,12 @@ 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; + //console.log("task:", i, timeouts[i]); + return i + ":" + timeouts[i]; }); }; }); @@ -71,7 +72,7 @@ } return null; }) - .then(function(results) { + .then(function(/*results*/) { var e = new Error("should not pass sync exception!"); e.FAIL = true; throw e; @@ -90,7 +91,7 @@ } function promiseTimeout(timeout) { - return new Promise(function(resolve, reject) { + return new Promise(function(resolve) { setTimeout(resolve, timeout); }); } @@ -99,7 +100,7 @@ .then(function() { console.info("PROBABLY PASSED"); 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. Do the results make sense?" ); }) .catch(function(e) {