index.js 764 B

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. 'use strict';
  2. var onetime = require('onetime');
  3. var setImmediateShim = require('set-immediate-shim');
  4. module.exports = function (arr, next, cb) {
  5. var failed = false;
  6. var count = 0;
  7. cb = cb || function () {};
  8. if (!Array.isArray(arr)) {
  9. throw new TypeError('First argument must be an array');
  10. }
  11. if (typeof next !== 'function') {
  12. throw new TypeError('Second argument must be a function');
  13. }
  14. var len = arr.length;
  15. if (!len) {
  16. cb();
  17. return;
  18. }
  19. function callback(err) {
  20. if (failed) {
  21. return;
  22. }
  23. if (err !== undefined && err !== null) {
  24. failed = true;
  25. cb(err);
  26. return;
  27. }
  28. if (++count === len) {
  29. cb();
  30. return;
  31. }
  32. }
  33. for (var i = 0; i < len; i++) {
  34. setImmediateShim(next, arr[i], i, onetime(callback, true));
  35. }
  36. };