aboutsummaryrefslogtreecommitdiff
path: root/node_modules/async/internal/eachOfLimit.js
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2016-11-03 01:33:53 +0100
committerFlorian Dold <florian.dold@gmail.com>2016-11-03 01:33:53 +0100
commitd1291f67551c58168af43698a359cb5ddfd266b0 (patch)
tree55a13ed29fe1915e3f42f1b1b7038dafa2e975a7 /node_modules/async/internal/eachOfLimit.js
parentd0a0695fb5d34996850723f7d4b1b59c3df909c2 (diff)
node_modules
Diffstat (limited to 'node_modules/async/internal/eachOfLimit.js')
-rw-r--r--node_modules/async/internal/eachOfLimit.js9
1 files changed, 7 insertions, 2 deletions
diff --git a/node_modules/async/internal/eachOfLimit.js b/node_modules/async/internal/eachOfLimit.js
index 27a94bfb8..e4c74bb12 100644
--- a/node_modules/async/internal/eachOfLimit.js
+++ b/node_modules/async/internal/eachOfLimit.js
@@ -21,6 +21,10 @@ var _onlyOnce = require('./onlyOnce');
var _onlyOnce2 = _interopRequireDefault(_onlyOnce);
+var _breakLoop = require('./breakLoop');
+
+var _breakLoop2 = _interopRequireDefault(_breakLoop);
+
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
function _eachOfLimit(limit) {
@@ -33,12 +37,13 @@ function _eachOfLimit(limit) {
var done = false;
var running = 0;
- function iterateeCallback(err) {
+ function iterateeCallback(err, value) {
running -= 1;
if (err) {
done = true;
callback(err);
- } else if (done && running <= 0) {
+ } else if (value === _breakLoop2.default || done && running <= 0) {
+ done = true;
return callback(null);
} else {
replenish();