1 files changed, 8 insertions, 4 deletions
diff --git a/lib/rejectLimit.js b/lib/rejectLimit.js
index 76e6ffc..d58b291 100644
--- a/lib/rejectLimit.js
+++ b/lib/rejectLimit.js
@@ -1,6 +1,6 @@
-import reject from './internal/reject';
-import doParallelLimit from './internal/doParallelLimit';
-
+import _reject from './internal/reject';
+import eachOfLimit from './internal/eachOfLimit'
+import awaitify from './internal/awaitify'
 /**
  * The same as [`reject`]{@link module:Collections.reject} but runs a maximum of `limit` async operations at a
  * time.
@@ -19,5 +19,9 @@ import doParallelLimit from './internal/doParallelLimit';
  * Invoked with (item, callback).
  * @param {Function} [callback] - A callback which is called after all the
  * `iteratee` functions have finished. Invoked with (err, results).
+ * @returns {Promise} a promise, if no callback is passed
  */
-export default doParallelLimit(reject);
+function rejectLimit (coll, limit, iteratee, callback) {
+    return _reject(eachOfLimit(limit), coll, iteratee, callback)
+}
+export default awaitify(rejectLimit, 4);