createTester.js 1.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950
  1. 'use strict';
  2. Object.defineProperty(exports, "__esModule", {
  3. value: true
  4. });
  5. exports.default = _createTester;
  6. var _noop = require('lodash/noop');
  7. var _noop2 = _interopRequireDefault(_noop);
  8. var _breakLoop = require('./breakLoop');
  9. var _breakLoop2 = _interopRequireDefault(_breakLoop);
  10. function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
  11. function _createTester(eachfn, check, getResult) {
  12. return function (arr, limit, iteratee, cb) {
  13. function done() {
  14. if (cb) {
  15. cb(null, getResult(false));
  16. }
  17. }
  18. function wrappedIteratee(x, _, callback) {
  19. if (!cb) return callback();
  20. iteratee(x, function (err, v) {
  21. // Check cb as another iteratee may have resolved with a
  22. // value or error since we started this iteratee
  23. if (cb && (err || check(v))) {
  24. if (err) cb(err);else cb(err, getResult(true, x));
  25. cb = iteratee = false;
  26. callback(err, _breakLoop2.default);
  27. } else {
  28. callback();
  29. }
  30. });
  31. }
  32. if (arguments.length > 3) {
  33. cb = cb || _noop2.default;
  34. eachfn(arr, limit, wrappedIteratee, done);
  35. } else {
  36. cb = iteratee;
  37. cb = cb || _noop2.default;
  38. iteratee = limit;
  39. eachfn(arr, wrappedIteratee, done);
  40. }
  41. };
  42. }
  43. module.exports = exports['default'];