Blame view

node_modules/async/eachOf.js 3.29 KB
6a9ffbcc   liuqimichale   地图点击事件
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
  'use strict';
  
  Object.defineProperty(exports, "__esModule", {
      value: true
  });
  
  exports.default = function (coll, iteratee, callback) {
      var eachOfImplementation = (0, _isArrayLike2.default)(coll) ? eachOfArrayLike : eachOfGeneric;
      eachOfImplementation(coll, (0, _wrapAsync2.default)(iteratee), callback);
  };
  
  var _isArrayLike = require('lodash/isArrayLike');
  
  var _isArrayLike2 = _interopRequireDefault(_isArrayLike);
  
  var _breakLoop = require('./internal/breakLoop');
  
  var _breakLoop2 = _interopRequireDefault(_breakLoop);
  
  var _eachOfLimit = require('./eachOfLimit');
  
  var _eachOfLimit2 = _interopRequireDefault(_eachOfLimit);
  
  var _doLimit = require('./internal/doLimit');
  
  var _doLimit2 = _interopRequireDefault(_doLimit);
  
  var _noop = require('lodash/noop');
  
  var _noop2 = _interopRequireDefault(_noop);
  
  var _once = require('./internal/once');
  
  var _once2 = _interopRequireDefault(_once);
  
  var _onlyOnce = require('./internal/onlyOnce');
  
  var _onlyOnce2 = _interopRequireDefault(_onlyOnce);
  
  var _wrapAsync = require('./internal/wrapAsync');
  
  var _wrapAsync2 = _interopRequireDefault(_wrapAsync);
  
  function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
  
  // eachOf implementation optimized for array-likes
  function eachOfArrayLike(coll, iteratee, callback) {
      callback = (0, _once2.default)(callback || _noop2.default);
      var index = 0,
          completed = 0,
          length = coll.length;
      if (length === 0) {
          callback(null);
      }
  
      function iteratorCallback(err, value) {
          if (err) {
              callback(err);
          } else if (++completed === length || value === _breakLoop2.default) {
              callback(null);
          }
      }
  
      for (; index < length; index++) {
          iteratee(coll[index], index, (0, _onlyOnce2.default)(iteratorCallback));
      }
  }
  
  // a generic version of eachOf which can handle array, object, and iterator cases.
  var eachOfGeneric = (0, _doLimit2.default)(_eachOfLimit2.default, Infinity);
  
  /**
   * Like [`each`]{@link module:Collections.each}, except that it passes the key (or index) as the second argument
   * to the iteratee.
   *
   * @name eachOf
   * @static
   * @memberOf module:Collections
   * @method
   * @alias forEachOf
   * @category Collection
   * @see [async.each]{@link module:Collections.each}
   * @param {Array|Iterable|Object} coll - A collection to iterate over.
   * @param {AsyncFunction} iteratee - A function to apply to each
   * item in `coll`.
   * The `key` is the item's key, or index in the case of an array.
   * Invoked with (item, key, callback).
   * @param {Function} [callback] - A callback which is called when all
   * `iteratee` functions have finished, or an error occurs. Invoked with (err).
   * @example
   *
   * var obj = {dev: "/dev.json", test: "/test.json", prod: "/prod.json"};
   * var configs = {};
   *
   * async.forEachOf(obj, function (value, key, callback) {
   *     fs.readFile(__dirname + value, "utf8", function (err, data) {
   *         if (err) return callback(err);
   *         try {
   *             configs[key] = JSON.parse(data);
   *         } catch (e) {
   *             return callback(e);
   *         }
   *         callback();
   *     });
   * }, function (err) {
   *     if (err) console.error(err.message);
   *     // configs is now a map of JSON data
   *     doSomethingWith(configs);
   * });
   */
  module.exports = exports['default'];