diff options
author | Florian Dold <florian.dold@gmail.com> | 2016-11-03 01:33:53 +0100 |
---|---|---|
committer | Florian Dold <florian.dold@gmail.com> | 2016-11-03 01:33:53 +0100 |
commit | d1291f67551c58168af43698a359cb5ddfd266b0 (patch) | |
tree | 55a13ed29fe1915e3f42f1b1b7038dafa2e975a7 /node_modules/async/internal/eachOfLimit.js | |
parent | d0a0695fb5d34996850723f7d4b1b59c3df909c2 (diff) |
node_modules
Diffstat (limited to 'node_modules/async/internal/eachOfLimit.js')
-rw-r--r-- | node_modules/async/internal/eachOfLimit.js | 9 |
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(); |