summaryrefslogtreecommitdiff
path: root/lib/internal/eachOfLimit.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/internal/eachOfLimit.js')
-rw-r--r--lib/internal/eachOfLimit.js5
1 files changed, 4 insertions, 1 deletions
diff --git a/lib/internal/eachOfLimit.js b/lib/internal/eachOfLimit.js
index ae153b1..2928366 100644
--- a/lib/internal/eachOfLimit.js
+++ b/lib/internal/eachOfLimit.js
@@ -9,7 +9,10 @@ import breakLoop from './breakLoop';
export default function _eachOfLimit(limit) {
return function (obj, iteratee, callback) {
callback = once(callback || noop);
- if (limit <= 0 || !obj) {
+ if (limit <= 0) {
+ throw new RangeError('concurrency limit cannot be less than 1')
+ }
+ if (!obj) {
return callback(null);
}
var nextElem = iterator(obj);