aboutsummaryrefslogtreecommitdiff
path: root/node_modules/async/internal/eachOfLimit.js
diff options
context:
space:
mode:
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();