lib/internal/doParallelLimit.js


1
2
3
4
5
6

import eachOfLimit from './eachOfLimit';
import wrapAsync from './wrapAsync';

export default function doParallelLimit(fn) {
    return (obj, limit, iteratee, cb) => fn(eachOfLimit(limit), obj, wrapAsync(iteratee), cb);
}