diff options
| author | Graeme Yeates <yeatesgraeme@gmail.com> | 2015-12-23 15:50:39 -0500 |
|---|---|---|
| committer | Graeme Yeates <yeatesgraeme@gmail.com> | 2015-12-29 16:48:48 -0500 |
| commit | 18e61d4f07f48604601f2effdbe2a7e188d14d4a (patch) | |
| tree | d4761428f57ec80816bea109124fd836cdaf20a6 | |
| parent | 7127b67f94a22247c36bf40e4f2685912e0f80e9 (diff) | |
| download | async-18e61d4f07f48604601f2effdbe2a7e188d14d4a.tar.gz | |
[WIP] modularization (#984)
494 files changed, 903 insertions, 5689 deletions
diff --git a/build/lodash-es b/build/lodash-es new file mode 160000 +Subproject 0406e7b95b891cfacb0b0b8f6be050095a10ab3 diff --git a/lib/apply/index.js b/lib/apply.js index e27ef80..f185597 100644 --- a/lib/apply/index.js +++ b/lib/apply.js @@ -1,8 +1,8 @@ 'use strict'; -var restParam = require('async.util.restparam'); +import restParam from 'lodash/function/restParam'; -module.exports = restParam(function(fn, args) { +export default restParam(function(fn, args) { return restParam(function(callArgs) { return fn.apply(null, args.concat(callArgs)); }); diff --git a/lib/apply/.editorconfig b/lib/apply/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/apply/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/apply/.gitignore b/lib/apply/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/apply/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/apply/.jscsrc b/lib/apply/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/apply/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/apply/.jshintrc b/lib/apply/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/apply/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/apply/README.md b/lib/apply/README.md deleted file mode 100644 index 3caa576..0000000 --- a/lib/apply/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.apply - - -[](https://david-dm.org/async-js/async.apply) -[](https://david-dm.org/async-js/async.apply#info=devDependencies) -[](https://www.npmjs.org/package/async.apply) -[](https://paypal.me/kikobeats) - -> [async#apply](https://github.com/async-js/async#async.apply) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/apply/package.json b/lib/apply/package.json deleted file mode 100644 index 6d8e5dc..0000000 --- a/lib/apply/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.apply", - "description": "async applymethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.restparam": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "apply" - ] -} diff --git a/lib/applyEach.js b/lib/applyEach.js new file mode 100644 index 0000000..90d2d6f --- /dev/null +++ b/lib/applyEach.js @@ -0,0 +1,6 @@ +'use strict'; + +import eachOf from './eachof'; +var applyEach = require('async.util.applyeach'); + +export default applyEach(eachOf); diff --git a/lib/applyEachSeries.js b/lib/applyEachSeries.js new file mode 100644 index 0000000..cf7577e --- /dev/null +++ b/lib/applyEachSeries.js @@ -0,0 +1,6 @@ +'use strict'; + +import eachOfSeries from './eachOfSeries'; +import applyEach from './applyEach'; + +export default applyEach(eachOfSeries); diff --git a/lib/applyeach/.editorconfig b/lib/applyeach/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/applyeach/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/applyeach/.gitignore b/lib/applyeach/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/applyeach/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/applyeach/.jscsrc b/lib/applyeach/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/applyeach/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/applyeach/.jshintrc b/lib/applyeach/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/applyeach/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/applyeach/README.md b/lib/applyeach/README.md deleted file mode 100644 index a8e68c3..0000000 --- a/lib/applyeach/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.applyeach - - -[](https://david-dm.org/async-js/async.applyeach) -[](https://david-dm.org/async-js/async.applyeach#info=devDependencies) -[](https://www.npmjs.org/package/async.applyeach) -[](https://paypal.me/kikobeats) - -> [async#applyeach](https://github.com/async-js/async#async.applyeach) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/applyeach/index.js b/lib/applyeach/index.js deleted file mode 100644 index 9519afd..0000000 --- a/lib/applyeach/index.js +++ /dev/null @@ -1,6 +0,0 @@ -'use strict'; - -var eachOf = require('async.eachof'); -var applyEach = require('async.util.applyeach'); - -module.exports = applyEach(eachOf); diff --git a/lib/applyeach/package.json b/lib/applyeach/package.json deleted file mode 100644 index 996beca..0000000 --- a/lib/applyeach/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.applyeach", - "description": "async applyeachmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachof": "0.5.2", - "async.util.applyeach": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "applyeach" - ] -} diff --git a/lib/applyeachseries/.editorconfig b/lib/applyeachseries/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/applyeachseries/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/applyeachseries/.gitignore b/lib/applyeachseries/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/applyeachseries/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/applyeachseries/.jscsrc b/lib/applyeachseries/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/applyeachseries/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/applyeachseries/.jshintrc b/lib/applyeachseries/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/applyeachseries/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/applyeachseries/README.md b/lib/applyeachseries/README.md deleted file mode 100644 index bedaee7..0000000 --- a/lib/applyeachseries/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.applyeachseries - - -[](https://david-dm.org/async-js/async.applyeachseries) -[](https://david-dm.org/async-js/async.applyeachseries#info=devDependencies) -[](https://www.npmjs.org/package/async.applyeachseries) -[](https://paypal.me/kikobeats) - -> [async#applyeachseries](https://github.com/async-js/async#async.applyeachseries) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/applyeachseries/index.js b/lib/applyeachseries/index.js deleted file mode 100644 index 8d4d3cf..0000000 --- a/lib/applyeachseries/index.js +++ /dev/null @@ -1,6 +0,0 @@ -'use strict'; - -var eachOfSeries = require('async.eachofseries'); -var applyEach = require('async.util.applyeach'); - -module.exports = applyEach(eachOfSeries); diff --git a/lib/applyeachseries/package.json b/lib/applyeachseries/package.json deleted file mode 100644 index 70ee71a..0000000 --- a/lib/applyeachseries/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.applyeachseries", - "description": "async applyeachseriesmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachofseries": "0.5.2", - "async.util.applyeach": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "applyeachseries" - ] -} diff --git a/lib/asyncify.js b/lib/asyncify.js new file mode 100644 index 0000000..6fdc62d --- /dev/null +++ b/lib/asyncify.js @@ -0,0 +1,26 @@ +'use strict'; + +import isObject from 'lodash/lang/isObject'; +import restParam from 'lodash/function/restParam'; + +export default function asyncify(func) { + return restParam(function (args) { + var callback = args.pop(); + var result; + try { + result = func.apply(this, args); + } catch (e) { + return callback(e); + } + // if result is Promise object + if (isObject(result) && typeof result.then === 'function') { + result.then(function(value) { + callback(null, value); + })['catch'](function(err) { + callback(err.message ? err : new Error(err)); + }); + } else { + callback(null, result); + } + }); +} diff --git a/lib/asyncify/.editorconfig b/lib/asyncify/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/asyncify/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/asyncify/.gitignore b/lib/asyncify/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/asyncify/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/asyncify/.jscsrc b/lib/asyncify/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/asyncify/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/asyncify/.jshintrc b/lib/asyncify/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/asyncify/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/asyncify/README.md b/lib/asyncify/README.md deleted file mode 100644 index 75f97bd..0000000 --- a/lib/asyncify/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.asyncify - - -[](https://david-dm.org/async-js/async.asyncify) -[](https://david-dm.org/async-js/async.asyncify#info=devDependencies) -[](https://www.npmjs.org/package/async.asyncify) -[](https://paypal.me/kikobeats) - -> [async#asyncify](https://github.com/async-js/async#async.asyncify) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/asyncify/index.js b/lib/asyncify/index.js deleted file mode 100644 index 063d221..0000000 --- a/lib/asyncify/index.js +++ /dev/null @@ -1,2 +0,0 @@ -'use strict'; -module.exports = require('async.util.asyncify'); diff --git a/lib/asyncify/package.json b/lib/asyncify/package.json deleted file mode 100644 index 4068529..0000000 --- a/lib/asyncify/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.asyncify", - "description": "async asyncifymethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.asyncify": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "asyncify" - ] -} diff --git a/lib/auto/index.js b/lib/auto.js index ec564e9..e48735c 100644 --- a/lib/auto/index.js +++ b/lib/auto.js @@ -1,25 +1,26 @@ 'use strict'; -var once = require('async.util.once'); -var noop = require('async.util.noop'); -var _keys = require('async.util.keys'); -var reduce = require('async.util.reduce'); -var indexOf = require('async.util.indexof'); -var isArray = require('async.util.isarray'); -var arrayEach = require('async.util.arrayeach'); -var restParam = require('async.util.restparam'); -var forEachOf = require('async.util.foreachof'); -var setImmediate = require('async.util.setimmediate'); +import arrayEach from 'lodash/internal/arrayEach'; +import forOwn from 'lodash/object/forOwn'; +import indexOf from 'lodash/array/indexOf'; +import isArray from 'lodash/lang/isArray'; +import keys from 'lodash/object/keys'; +import noop from 'lodash/utility/noop'; +import once from 'lodash/function/once'; +import restParam from 'lodash/function/restParam'; -module.exports = function auto(tasks, concurrency, cb) { +import reduce from './reduce'; +import setImmediate from './internal/setImmediate'; + +export default function auto(tasks, concurrency, cb) { if (typeof arguments[1] === 'function') { // concurrency is optional, shift the args. cb = concurrency; concurrency = null; } cb = once(cb || noop); - var keys = _keys(tasks); - var remainingTasks = keys.length; + var okeys = keys(tasks); + var remainingTasks = okeys.length; if (!remainingTasks) { return cb(null); } @@ -43,7 +44,7 @@ module.exports = function auto(tasks, concurrency, cb) { function taskComplete() { remainingTasks--; - arrayEach(listeners.slice(0), function(fn) { + arrayEach(listeners, function(fn) { fn(); }); } @@ -54,7 +55,7 @@ module.exports = function auto(tasks, concurrency, cb) { } }); - arrayEach(keys, function(k) { + arrayEach(okeys, function(k) { var task = isArray(tasks[k]) ? tasks[k] : [tasks[k]]; var taskCallback = restParam(function(err, args) { runningTasks--; @@ -63,7 +64,7 @@ module.exports = function auto(tasks, concurrency, cb) { } if (err) { var safeResults = {}; - forEachOf(results, function(val, rkey) { + forOwn(results, function(val, rkey) { safeResults[rkey] = val; }); safeResults[k] = args; @@ -106,4 +107,4 @@ module.exports = function auto(tasks, concurrency, cb) { } } }); -}; +} diff --git a/lib/auto/.editorconfig b/lib/auto/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/auto/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/auto/.gitignore b/lib/auto/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/auto/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/auto/.jscsrc b/lib/auto/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/auto/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/auto/.jshintrc b/lib/auto/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/auto/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/auto/README.md b/lib/auto/README.md deleted file mode 100644 index 2028ee5..0000000 --- a/lib/auto/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.auto - - -[](https://david-dm.org/async-js/async.auto) -[](https://david-dm.org/async-js/async.auto#info=devDependencies) -[](https://www.npmjs.org/package/async.auto) -[](https://paypal.me/kikobeats) - -> [async#auto](https://github.com/async-js/async#async.auto) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/auto/package.json b/lib/auto/package.json deleted file mode 100644 index 6fc0097..0000000 --- a/lib/auto/package.json +++ /dev/null @@ -1,29 +0,0 @@ -{ - "name": "async.auto", - "description": "async automethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.arrayeach": "0.5.2", - "async.util.foreachof": "0.5.2", - "async.util.indexof": "0.5.2", - "async.util.isarray": "0.5.2", - "async.util.keys": "0.5.2", - "async.util.noop": "0.5.2", - "async.util.once": "0.5.2", - "async.util.reduce": "0.5.2", - "async.util.restparam": "0.5.2", - "async.util.setimmediate": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "auto" - ] -} diff --git a/lib/cargo.js b/lib/cargo.js new file mode 100644 index 0000000..b90ab0f --- /dev/null +++ b/lib/cargo.js @@ -0,0 +1,7 @@ +'use strict'; + +import queue from './internal/queue'; + +export default function cargo(worker, payload) { + return queue(worker, 1, payload); +} diff --git a/lib/cargo/.editorconfig b/lib/cargo/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/cargo/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/cargo/.gitignore b/lib/cargo/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/cargo/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/cargo/.jscsrc b/lib/cargo/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/cargo/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/cargo/.jshintrc b/lib/cargo/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/cargo/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/cargo/README.md b/lib/cargo/README.md deleted file mode 100644 index 68835cc..0000000 --- a/lib/cargo/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.cargo - - -[](https://david-dm.org/async-js/async.cargo) -[](https://david-dm.org/async-js/async.cargo#info=devDependencies) -[](https://www.npmjs.org/package/async.cargo) -[](https://paypal.me/kikobeats) - -> [async#cargo](https://github.com/async-js/async#async.cargo) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/cargo/index.js b/lib/cargo/index.js deleted file mode 100644 index fdaa80c..0000000 --- a/lib/cargo/index.js +++ /dev/null @@ -1,7 +0,0 @@ -'use strict'; - -var queue = require('async.util.queue'); - -module.exports = function cargo(worker, payload) { - return queue(worker, 1, payload); -}; diff --git a/lib/cargo/package.json b/lib/cargo/package.json deleted file mode 100644 index c2efd29..0000000 --- a/lib/cargo/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.cargo", - "description": "async cargomethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.queue": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "cargo" - ] -} diff --git a/lib/compose.js b/lib/compose.js new file mode 100644 index 0000000..9e92521 --- /dev/null +++ b/lib/compose.js @@ -0,0 +1,9 @@ +'use strict'; + +import seq from './seq'; + +var reverse = Array.prototype.reverse; + +export default function compose(/* functions... */) { + return seq.apply(null, reverse.call(arguments)); +} diff --git a/lib/compose/.editorconfig b/lib/compose/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/compose/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/compose/.gitignore b/lib/compose/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/compose/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/compose/.jscsrc b/lib/compose/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/compose/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/compose/.jshintrc b/lib/compose/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/compose/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/compose/README.md b/lib/compose/README.md deleted file mode 100644 index dfdaaed..0000000 --- a/lib/compose/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.compose - - -[](https://david-dm.org/async-js/async.compose) -[](https://david-dm.org/async-js/async.compose#info=devDependencies) -[](https://www.npmjs.org/package/async.compose) -[](https://paypal.me/kikobeats) - -> [async#compose](https://github.com/async-js/async#async.compose) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/compose/index.js b/lib/compose/index.js deleted file mode 100644 index 4f81825..0000000 --- a/lib/compose/index.js +++ /dev/null @@ -1,7 +0,0 @@ -'use strict'; - -var seq = require('async.seq'); - -module.exports = function compose(/* functions... */) { - return seq.apply(null, Array.prototype.reverse.call(arguments)); -}; diff --git a/lib/compose/package.json b/lib/compose/package.json deleted file mode 100644 index bfa2ea8..0000000 --- a/lib/compose/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.compose", - "description": "async composemethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.seq": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "compose" - ] -} diff --git a/lib/concat.js b/lib/concat.js new file mode 100644 index 0000000..af019a3 --- /dev/null +++ b/lib/concat.js @@ -0,0 +1,6 @@ +'use strict'; + +import concat from './internal/concat'; +import doParallel from './internal/doParallel'; + +export default doParallel(concat); diff --git a/lib/concat/.editorconfig b/lib/concat/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/concat/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/concat/.gitignore b/lib/concat/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/concat/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/concat/.jscsrc b/lib/concat/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/concat/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/concat/.jshintrc b/lib/concat/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/concat/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/concat/README.md b/lib/concat/README.md deleted file mode 100644 index 62c4b62..0000000 --- a/lib/concat/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.concat - - -[](https://david-dm.org/async-js/async.concat) -[](https://david-dm.org/async-js/async.concat#info=devDependencies) -[](https://www.npmjs.org/package/async.concat) -[](https://paypal.me/kikobeats) - -> [async#concat](https://github.com/async-js/async#async.concat) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/concat/index.js b/lib/concat/index.js deleted file mode 100644 index 3ff5e34..0000000 --- a/lib/concat/index.js +++ /dev/null @@ -1,6 +0,0 @@ -'use strict'; - -var concat = require('async.util.concat'); -var doParallel = require('async.util.doparallel'); - -module.exports = doParallel(concat); diff --git a/lib/concat/package.json b/lib/concat/package.json deleted file mode 100644 index 091ff26..0000000 --- a/lib/concat/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.concat", - "description": "async concatmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.concat": "0.5.2", - "async.util.doparallel": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "concat" - ] -} diff --git a/lib/concatSeries.js b/lib/concatSeries.js new file mode 100644 index 0000000..76f4043 --- /dev/null +++ b/lib/concatSeries.js @@ -0,0 +1,6 @@ +'use strict'; + +import concat from './internal/concat'; +import doSeries from './internal/doSeries'; + +export default doSeries(concat); diff --git a/lib/concatseries/.editorconfig b/lib/concatseries/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/concatseries/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/concatseries/.gitignore b/lib/concatseries/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/concatseries/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/concatseries/.jscsrc b/lib/concatseries/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/concatseries/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/concatseries/.jshintrc b/lib/concatseries/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/concatseries/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/concatseries/README.md b/lib/concatseries/README.md deleted file mode 100644 index 9264b89..0000000 --- a/lib/concatseries/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.concatseries - - -[](https://david-dm.org/async-js/async.concatseries) -[](https://david-dm.org/async-js/async.concatseries#info=devDependencies) -[](https://www.npmjs.org/package/async.concatseries) -[](https://paypal.me/kikobeats) - -> [async#concatseries](https://github.com/async-js/async#async.concatseries) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/concatseries/index.js b/lib/concatseries/index.js deleted file mode 100644 index 657246e..0000000 --- a/lib/concatseries/index.js +++ /dev/null @@ -1,6 +0,0 @@ -'use strict'; - -var concat = require('async.util.concat'); -var doSeries = require('async.util.doseries'); - -module.exports = doSeries(concat); diff --git a/lib/concatseries/package.json b/lib/concatseries/package.json deleted file mode 100644 index 632b3cc..0000000 --- a/lib/concatseries/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.concatseries", - "description": "async concatseriesmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.concat": "0.5.2", - "async.util.doseries": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "concatseries" - ] -} diff --git a/lib/constant/index.js b/lib/constant.js index 6b9d5bc..7d6a800 100644 --- a/lib/constant/index.js +++ b/lib/constant.js @@ -1,8 +1,8 @@ 'use strict'; -var restParam = require('async.util.restparam'); +import restParam from 'lodash/function/restParam'; -module.exports = restParam(function(values) { +export default restParam(function(values) { var args = [null].concat(values); return function (cb) { return cb.apply(this, args); diff --git a/lib/constant/.editorconfig b/lib/constant/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/constant/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/constant/.gitignore b/lib/constant/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/constant/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/constant/.jscsrc b/lib/constant/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/constant/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/constant/.jshintrc b/lib/constant/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/constant/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/constant/README.md b/lib/constant/README.md deleted file mode 100644 index 18b7b65..0000000 --- a/lib/constant/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.constant - - -[](https://david-dm.org/async-js/async.constant) -[](https://david-dm.org/async-js/async.constant#info=devDependencies) -[](https://www.npmjs.org/package/async.constant) -[](https://paypal.me/kikobeats) - -> [async#constant](https://github.com/async-js/async#async.constant) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/constant/package.json b/lib/constant/package.json deleted file mode 100644 index 81d1349..0000000 --- a/lib/constant/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.constant", - "description": "async constantmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.restparam": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "constant" - ] -} diff --git a/lib/detect.js b/lib/detect.js new file mode 100644 index 0000000..8cd7a8e --- /dev/null +++ b/lib/detect.js @@ -0,0 +1,9 @@ +'use strict'; + +import identity from 'lodash/utility/identity'; + +import createTester from './internal/createTester'; +import eachOf from './eachOf'; +import findGetResult from './internal/findGetResult'; + +export default createTester(eachOf, identity, findGetResult); diff --git a/lib/detect/.editorconfig b/lib/detect/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/detect/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/detect/.gitignore b/lib/detect/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/detect/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/detect/.jscsrc b/lib/detect/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/detect/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/detect/.jshintrc b/lib/detect/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/detect/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/detect/README.md b/lib/detect/README.md deleted file mode 100644 index 3d6cb65..0000000 --- a/lib/detect/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.detect - - -[](https://david-dm.org/async-js/async.detect) -[](https://david-dm.org/async-js/async.detect#info=devDependencies) -[](https://www.npmjs.org/package/async.detect) -[](https://paypal.me/kikobeats) - -> [async#detect](https://github.com/async-js/async#async.detect) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/detect/index.js b/lib/detect/index.js deleted file mode 100644 index 97383c0..0000000 --- a/lib/detect/index.js +++ /dev/null @@ -1,8 +0,0 @@ -'use strict'; - -var eachOf = require('async.eachof'); -var identity = require('async.util.identity'); -var createTester = require('async.util.createtester'); -var findGetResult = require('async.util.findgetresult'); - -module.exports = createTester(eachOf, identity, findGetResult); diff --git a/lib/detect/package.json b/lib/detect/package.json deleted file mode 100644 index 81a36d2..0000000 --- a/lib/detect/package.json +++ /dev/null @@ -1,23 +0,0 @@ -{ - "name": "async.detect", - "description": "async detectmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachof": "0.5.2", - "async.util.createtester": "0.5.2", - "async.util.findgetresult": "0.5.2", - "async.util.identity": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "detect" - ] -} diff --git a/lib/detectLimit.js b/lib/detectLimit.js new file mode 100644 index 0000000..74a2003 --- /dev/null +++ b/lib/detectLimit.js @@ -0,0 +1,9 @@ +'use strict'; + +import identity from 'lodash/utility/identity'; + +import createTester from './internal/createTester'; +import eachOfLimit from './eachOfLimit'; +import findGetResult from './internal/findGetResult'; + +export default createTester(eachOfLimit, identity, findGetResult); diff --git a/lib/detectSeries.js b/lib/detectSeries.js new file mode 100644 index 0000000..717685e --- /dev/null +++ b/lib/detectSeries.js @@ -0,0 +1,9 @@ +'use strict'; + +import identity from 'lodash/utility/identity'; + +import createTester from './internal/createTester'; +import eachOfSeries from './eachOfSeries'; +import findGetResult from './internal/findGetResult'; + +export default createTester(eachOfSeries, identity, findGetResult); diff --git a/lib/detectlimit/.editorconfig b/lib/detectlimit/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/detectlimit/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/detectlimit/.gitignore b/lib/detectlimit/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/detectlimit/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/detectlimit/.jscsrc b/lib/detectlimit/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/detectlimit/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/detectlimit/.jshintrc b/lib/detectlimit/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/detectlimit/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/detectlimit/README.md b/lib/detectlimit/README.md deleted file mode 100644 index 979a3bc..0000000 --- a/lib/detectlimit/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.detectlimit - - -[](https://david-dm.org/async-js/async.detectlimit) -[](https://david-dm.org/async-js/async.detectlimit#info=devDependencies) -[](https://www.npmjs.org/package/async.detectlimit) -[](https://paypal.me/kikobeats) - -> [async#detectlimit](https://github.com/async-js/async#async.detectlimit) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/detectlimit/index.js b/lib/detectlimit/index.js deleted file mode 100644 index a5e21cf..0000000 --- a/lib/detectlimit/index.js +++ /dev/null @@ -1,8 +0,0 @@ -'use strict'; - -var identity = require('async.util.identity'); -var eachOfLimit = require('async.eachoflimit'); -var createTester = require('async.util.createtester'); -var findGetResult = require('async.util.findgetresult'); - -module.exports = createTester(eachOfLimit, identity, findGetResult); diff --git a/lib/detectlimit/package.json b/lib/detectlimit/package.json deleted file mode 100644 index 72892ca..0000000 --- a/lib/detectlimit/package.json +++ /dev/null @@ -1,23 +0,0 @@ -{ - "name": "async.detectlimit", - "description": "async detectlimitmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachoflimit": "0.5.2", - "async.util.createtester": "0.5.2", - "async.util.findgetresult": "0.5.2", - "async.util.identity": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "detectlimit" - ] -} diff --git a/lib/detectseries/.editorconfig b/lib/detectseries/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/detectseries/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/detectseries/.gitignore b/lib/detectseries/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/detectseries/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/detectseries/.jscsrc b/lib/detectseries/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/detectseries/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/detectseries/.jshintrc b/lib/detectseries/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/detectseries/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/detectseries/README.md b/lib/detectseries/README.md deleted file mode 100644 index 3cd78ab..0000000 --- a/lib/detectseries/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.detectseries - - -[](https://david-dm.org/async-js/async.detectseries) -[](https://david-dm.org/async-js/async.detectseries#info=devDependencies) -[](https://www.npmjs.org/package/async.detectseries) -[](https://paypal.me/kikobeats) - -> [async#detectseries](https://github.com/async-js/async#async.detectseries) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/detectseries/index.js b/lib/detectseries/index.js deleted file mode 100644 index 29ecab2..0000000 --- a/lib/detectseries/index.js +++ /dev/null @@ -1,8 +0,0 @@ -'use strict'; - -var identity = require('async.util.identity'); -var eachOfSeries = require('async.eachofseries'); -var createTester = require('async.util.createtester'); -var findGetResult = require('async.util.findgetresult'); - -module.exports = createTester(eachOfSeries, identity, findGetResult); diff --git a/lib/detectseries/package.json b/lib/detectseries/package.json deleted file mode 100644 index 4b52f3b..0000000 --- a/lib/detectseries/package.json +++ /dev/null @@ -1,23 +0,0 @@ -{ - "name": "async.detectseries", - "description": "async detectseriesmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachofseries": "0.5.2", - "async.util.createtester": "0.5.2", - "async.util.findgetresult": "0.5.2", - "async.util.identity": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "detectseries" - ] -} diff --git a/lib/dir.js b/lib/dir.js new file mode 100644 index 0000000..049b416 --- /dev/null +++ b/lib/dir.js @@ -0,0 +1,5 @@ +'use strict'; + +import consoleFunc from './internal/consoleFunc'; + +export default consoleFunc('dir'); diff --git a/lib/dir/.editorconfig b/lib/dir/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/dir/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/dir/.gitignore b/lib/dir/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/dir/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/dir/.jscsrc b/lib/dir/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/dir/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/dir/.jshintrc b/lib/dir/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/dir/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/dir/README.md b/lib/dir/README.md deleted file mode 100644 index 286d9cf..0000000 --- a/lib/dir/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.dir - - -[](https://david-dm.org/async-js/async.dir) -[](https://david-dm.org/async-js/async.dir#info=devDependencies) -[](https://www.npmjs.org/package/async.dir) -[](https://paypal.me/kikobeats) - -> [async#dir](https://github.com/async-js/async#async.dir) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/dir/index.js b/lib/dir/index.js deleted file mode 100644 index 14d004f..0000000 --- a/lib/dir/index.js +++ /dev/null @@ -1,2 +0,0 @@ -'use strict'; -module.exports = require('async.util.consolefn')('dir'); diff --git a/lib/dir/package.json b/lib/dir/package.json deleted file mode 100644 index f2a9726..0000000 --- a/lib/dir/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.dir", - "description": "async dirmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.consolefn": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "dir" - ] -} diff --git a/lib/doduring/index.js b/lib/doDuring.js index 211103c..c13e62b 100644 --- a/lib/doduring/index.js +++ b/lib/doDuring.js @@ -1,12 +1,12 @@ 'use strict'; -var during = require('async.during'); +import during from './during'; -module.exports = function doDuring(iterator, test, cb) { +export default function doDuring(iterator, test, cb) { var calls = 0; during(function(next) { if (calls++ < 1) return next(null, true); test.apply(this, arguments); }, iterator, cb); -}; +} diff --git a/lib/dountil/index.js b/lib/doUntil.js index 7a9b0e8..3bc783f 100644 --- a/lib/dountil/index.js +++ b/lib/doUntil.js @@ -1,9 +1,9 @@ 'use strict'; -var doWhilst = require('async.dowhilst'); +import doWhilst from './doWhilst'; -module.exports = function doUntil(iterator, test, cb) { +export default function doUntil(iterator, test, cb) { return doWhilst(iterator, function() { return !test.apply(this, arguments); }, cb); -}; +} diff --git a/lib/dowhilst/index.js b/lib/doWhilst.js index f28c0cc..0603f2a 100644 --- a/lib/dowhilst/index.js +++ b/lib/doWhilst.js @@ -1,8 +1,8 @@ 'use strict'; -var whilst = require('async.whilst'); +import whilst from './whilst'; -module.exports = function doWhilst(iterator, test, cb) { +export default function doWhilst(iterator, test, cb) { var calls = 0; return whilst(function() { return ++calls <= 1 || test.apply(this, arguments); diff --git a/lib/doduring/.editorconfig b/lib/doduring/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/doduring/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/doduring/.gitignore b/lib/doduring/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/doduring/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/doduring/.jscsrc b/lib/doduring/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/doduring/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/doduring/.jshintrc b/lib/doduring/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/doduring/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/doduring/README.md b/lib/doduring/README.md deleted file mode 100644 index ac0e0d4..0000000 --- a/lib/doduring/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.doduring - - -[](https://david-dm.org/async-js/async.doduring) -[](https://david-dm.org/async-js/async.doduring#info=devDependencies) -[](https://www.npmjs.org/package/async.doduring) -[](https://paypal.me/kikobeats) - -> [async#doduring](https://github.com/async-js/async#async.doduring) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/doduring/package.json b/lib/doduring/package.json deleted file mode 100644 index a0c2a99..0000000 --- a/lib/doduring/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.doduring", - "description": "async doduringmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.during": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "doduring" - ] -} diff --git a/lib/dountil/.editorconfig b/lib/dountil/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/dountil/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/dountil/.gitignore b/lib/dountil/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/dountil/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/dountil/.jscsrc b/lib/dountil/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/dountil/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/dountil/.jshintrc b/lib/dountil/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/dountil/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/dountil/README.md b/lib/dountil/README.md deleted file mode 100644 index ec915cf..0000000 --- a/lib/dountil/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.dountil - - -[](https://david-dm.org/async-js/async.dountil) -[](https://david-dm.org/async-js/async.dountil#info=devDependencies) -[](https://www.npmjs.org/package/async.dountil) -[](https://paypal.me/kikobeats) - -> [async#dountil](https://github.com/async-js/async#async.dountil) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/dountil/package.json b/lib/dountil/package.json deleted file mode 100644 index 3be22ff..0000000 --- a/lib/dountil/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.dountil", - "description": "async dountilmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.dowhilst": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "dountil" - ] -} diff --git a/lib/dowhilst/.editorconfig b/lib/dowhilst/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/dowhilst/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/dowhilst/.gitignore b/lib/dowhilst/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/dowhilst/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/dowhilst/.jscsrc b/lib/dowhilst/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/dowhilst/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/dowhilst/.jshintrc b/lib/dowhilst/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/dowhilst/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/dowhilst/README.md b/lib/dowhilst/README.md deleted file mode 100644 index 8b5c027..0000000 --- a/lib/dowhilst/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.dowhilst - - -[](https://david-dm.org/async-js/async.dowhilst) -[](https://david-dm.org/async-js/async.dowhilst#info=devDependencies) -[](https://www.npmjs.org/package/async.dowhilst) -[](https://paypal.me/kikobeats) - -> [async#dowhilst](https://github.com/async-js/async#async.dowhilst) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/dowhilst/package.json b/lib/dowhilst/package.json deleted file mode 100644 index 4717ae1..0000000 --- a/lib/dowhilst/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.dowhilst", - "description": "async dowhilstmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.whilst": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "dowhilst" - ] -} diff --git a/lib/during/index.js b/lib/during.js index 67b6e44..074d0da 100644 --- a/lib/during/index.js +++ b/lib/during.js @@ -1,9 +1,9 @@ 'use strict'; -var noop = require('async.util.noop'); -var restParam = require('async.util.restparam'); +import noop from 'lodash/utility/noop'; +import restParam from 'lodash/function/restParam'; -module.exports = function during(test, iterator, cb) { +export default function during(test, iterator, cb) { cb = cb || noop; var next = restParam(function(err, args) { @@ -22,4 +22,4 @@ module.exports = function during(test, iterator, cb) { }; test(check); -}; +} diff --git a/lib/during/.editorconfig b/lib/during/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/during/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/during/.gitignore b/lib/during/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/during/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/during/.jscsrc b/lib/during/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/during/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/during/.jshintrc b/lib/during/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/during/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/during/README.md b/lib/during/README.md deleted file mode 100644 index 81071dc..0000000 --- a/lib/during/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.during - - -[](https://david-dm.org/async-js/async.during) -[](https://david-dm.org/async-js/async.during#info=devDependencies) -[](https://www.npmjs.org/package/async.during) -[](https://paypal.me/kikobeats) - -> [async#during](https://github.com/async-js/async#async.during) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/during/package.json b/lib/during/package.json deleted file mode 100644 index a2093ca..0000000 --- a/lib/during/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.during", - "description": "async duringmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.noop": "0.5.2", - "async.util.restparam": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "during" - ] -} diff --git a/lib/each.js b/lib/each.js new file mode 100644 index 0000000..384bb0a --- /dev/null +++ b/lib/each.js @@ -0,0 +1,8 @@ +'use strict'; + +import eachOf from './eachOf'; +import withoutIndex from './internal/withoutIndex'; + +export default function each(arr, iterator, cb) { + return eachOf(arr, withoutIndex(iterator), cb); +} diff --git a/lib/each/.editorconfig b/lib/each/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/each/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/each/.gitignore b/lib/each/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/each/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/each/.jscsrc b/lib/each/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/each/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/each/.jshintrc b/lib/each/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/each/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/each/README.md b/lib/each/README.md deleted file mode 100644 index 07f3e36..0000000 --- a/lib/each/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.each - - -[](https://david-dm.org/async-js/async.each) -[](https://david-dm.org/async-js/async.each#info=devDependencies) -[](https://www.npmjs.org/package/async.each) -[](https://paypal.me/kikobeats) - -> [async#each](https://github.com/async-js/async#async.each) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/each/index.js b/lib/each/index.js deleted file mode 100644 index 39a10ff..0000000 --- a/lib/each/index.js +++ /dev/null @@ -1,8 +0,0 @@ -'use strict'; - -var eachOf = require('async.eachof'); -var withoutIndex = require('async.util.withoutindex'); - -module.exports = function each(arr, iterator, cb) { - return eachOf(arr, withoutIndex(iterator), cb); -}; diff --git a/lib/each/package.json b/lib/each/package.json deleted file mode 100644 index 61bb1d2..0000000 --- a/lib/each/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.each", - "description": "async eachmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachof": "0.5.2", - "async.util.withoutindex": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "each" - ] -} diff --git a/lib/eachLimit.js b/lib/eachLimit.js new file mode 100644 index 0000000..811a99a --- /dev/null +++ b/lib/eachLimit.js @@ -0,0 +1,9 @@ +'use strict'; + +import eachOfLimit from './eachOfLimit'; +import withoutIndex from './internal/withoutIndex'; + + +export default function eachLimit(arr, limit, iterator, cb) { + return eachOfLimit(limit)(arr, withoutIndex(iterator), cb); +} diff --git a/lib/eachof/index.js b/lib/eachOf.js index 6374b22..bad6700 100644 --- a/lib/eachof/index.js +++ b/lib/eachOf.js @@ -1,11 +1,12 @@ 'use strict'; -var once = require('async.util.once'); -var noop = require('async.util.noop'); -var onlyOnce = require('async.util.onlyonce'); -var keyIterator = require('async.util.keyiterator'); +import once from 'lodash/function/once'; +import noop from 'lodash/utility/noop'; -module.exports = function eachOf(object, iterator, callback) { +import keyIterator from './internal/keyIterator'; +import onlyOnce from './internal/onlyOnce'; + +export default function eachOf(object, iterator, callback) { callback = once(callback || noop); object = object || []; @@ -30,4 +31,4 @@ module.exports = function eachOf(object, iterator, callback) { callback(null); } } -}; +} diff --git a/lib/eachOfLimit.js b/lib/eachOfLimit.js new file mode 100644 index 0000000..e381474 --- /dev/null +++ b/lib/eachOfLimit.js @@ -0,0 +1,7 @@ +'use strict'; + +import _eachOfLimit from './internal/eachOfLimit'; + +export default function eachOfLimit(obj, limit, iterator, cb) { + _eachOfLimit(limit)(obj, iterator, cb); +} diff --git a/lib/eachofseries/index.js b/lib/eachOfSeries.js index f7e9450..8dd8eca 100644 --- a/lib/eachofseries/index.js +++ b/lib/eachOfSeries.js @@ -1,12 +1,13 @@ 'use strict'; -var once = require('async.util.once'); -var noop = require('async.util.noop'); -var onlyOnce = require('async.util.onlyonce'); -var keyIterator = require('async.util.keyiterator'); -var setImmediate = require('async.util.setimmediate'); +import once from 'lodash/function/once'; +import noop from 'lodash/utility/noop'; -module.exports = function eachOfSeries(obj, iterator, callback) { +import keyIterator from './internal/keyIterator'; +import onlyOnce from './internal/onlyOnce'; +import setImmediate from './setImmediate'; + +export default function eachOfSeries(obj, iterator, callback) { callback = once(callback || noop); obj = obj || []; var nextKey = keyIterator(obj); @@ -36,4 +37,4 @@ module.exports = function eachOfSeries(obj, iterator, callback) { sync = false; } iterate(); -}; +} diff --git a/lib/eachSeries.js b/lib/eachSeries.js new file mode 100644 index 0000000..fd08c04 --- /dev/null +++ b/lib/eachSeries.js @@ -0,0 +1,8 @@ +'use strict'; + +import eachOfSeries from './eachOfSeries'; +import withoutIndex from './internal/withoutIndex'; + +export default function eachSeries(arr, iterator, cb) { + return eachOfSeries(arr, withoutIndex(iterator), cb); +} diff --git a/lib/eachlimit/.editorconfig b/lib/eachlimit/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/eachlimit/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/eachlimit/.gitignore b/lib/eachlimit/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/eachlimit/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/eachlimit/.jscsrc b/lib/eachlimit/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/eachlimit/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/eachlimit/.jshintrc b/lib/eachlimit/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/eachlimit/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/eachlimit/README.md b/lib/eachlimit/README.md deleted file mode 100644 index a798125..0000000 --- a/lib/eachlimit/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.eachlimit - - -[](https://david-dm.org/async-js/async.eachlimit) -[](https://david-dm.org/async-js/async.eachlimit#info=devDependencies) -[](https://www.npmjs.org/package/async.eachlimit) -[](https://paypal.me/kikobeats) - -> [async#eachlimit](https://github.com/async-js/async#async.eachlimit) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/eachlimit/index.js b/lib/eachlimit/index.js deleted file mode 100644 index 5e11750..0000000 --- a/lib/eachlimit/index.js +++ /dev/null @@ -1,8 +0,0 @@ -'use strict'; - -var eachOfLimit = require('async.util.eachoflimit'); -var withoutIndex = require('async.util.withoutindex'); - -module.exports = function eachLimit(arr, limit, iterator, cb) { - return eachOfLimit(limit)(arr, withoutIndex(iterator), cb); -}; diff --git a/lib/eachlimit/package.json b/lib/eachlimit/package.json deleted file mode 100644 index d800da7..0000000 --- a/lib/eachlimit/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.eachlimit", - "description": "async eachlimitmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.eachoflimit": "0.5.2", - "async.util.withoutindex": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "eachlimit" - ] -} diff --git a/lib/eachof/.editorconfig b/lib/eachof/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/eachof/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/eachof/.gitignore b/lib/eachof/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/eachof/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/eachof/.jscsrc b/lib/eachof/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/eachof/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/eachof/.jshintrc b/lib/eachof/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/eachof/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/eachof/README.md b/lib/eachof/README.md deleted file mode 100644 index 122cbdb..0000000 --- a/lib/eachof/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.eachof - - -[](https://david-dm.org/async-js/async.eachof) -[](https://david-dm.org/async-js/async.eachof#info=devDependencies) -[](https://www.npmjs.org/package/async.eachof) -[](https://paypal.me/kikobeats) - -> [async#eachof](https://github.com/async-js/async#async.eachof) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/eachof/package.json b/lib/eachof/package.json deleted file mode 100644 index e697e4b..0000000 --- a/lib/eachof/package.json +++ /dev/null @@ -1,23 +0,0 @@ -{ - "name": "async.eachof", - "description": "async eachofmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.keyiterator": "0.5.2", - "async.util.noop": "0.5.2", - "async.util.once": "0.5.2", - "async.util.onlyonce": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "eachof" - ] -} diff --git a/lib/eachoflimit/.editorconfig b/lib/eachoflimit/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/eachoflimit/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/eachoflimit/.gitignore b/lib/eachoflimit/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/eachoflimit/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/eachoflimit/.jscsrc b/lib/eachoflimit/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/eachoflimit/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/eachoflimit/.jshintrc b/lib/eachoflimit/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/eachoflimit/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/eachoflimit/README.md b/lib/eachoflimit/README.md deleted file mode 100644 index fadb907..0000000 --- a/lib/eachoflimit/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.eachoflimit - - -[](https://david-dm.org/async-js/async.eachoflimit) -[](https://david-dm.org/async-js/async.eachoflimit#info=devDependencies) -[](https://www.npmjs.org/package/async.eachoflimit) -[](https://paypal.me/kikobeats) - -> [async#eachoflimit](https://github.com/async-js/async#async.eachoflimit) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/eachoflimit/index.js b/lib/eachoflimit/index.js deleted file mode 100644 index fe4574d..0000000 --- a/lib/eachoflimit/index.js +++ /dev/null @@ -1,7 +0,0 @@ -'use strict'; - -var _eachOfLimit = require('async.util.eachoflimit'); - -module.exports = function eachOfLimit(obj, limit, iterator, cb) { - _eachOfLimit(limit)(obj, iterator, cb); -}; diff --git a/lib/eachoflimit/package.json b/lib/eachoflimit/package.json deleted file mode 100644 index f13e974..0000000 --- a/lib/eachoflimit/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.eachoflimit", - "description": "async eachoflimitmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.eachoflimit": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "eachoflimit" - ] -} diff --git a/lib/eachofseries/.editorconfig b/lib/eachofseries/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/eachofseries/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/eachofseries/.gitignore b/lib/eachofseries/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/eachofseries/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/eachofseries/.jscsrc b/lib/eachofseries/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/eachofseries/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/eachofseries/.jshintrc b/lib/eachofseries/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/eachofseries/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/eachofseries/README.md b/lib/eachofseries/README.md deleted file mode 100644 index 848103c..0000000 --- a/lib/eachofseries/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.eachofseries - - -[](https://david-dm.org/async-js/async.eachofseries) -[](https://david-dm.org/async-js/async.eachofseries#info=devDependencies) -[](https://www.npmjs.org/package/async.eachofseries) -[](https://paypal.me/kikobeats) - -> [async#eachofseries](https://github.com/async-js/async#async.eachofseries) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/eachofseries/package.json b/lib/eachofseries/package.json deleted file mode 100644 index b648b7f..0000000 --- a/lib/eachofseries/package.json +++ /dev/null @@ -1,24 +0,0 @@ -{ - "name": "async.eachofseries", - "description": "async eachofseriesmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.keyiterator": "0.5.2", - "async.util.noop": "0.5.2", - "async.util.once": "0.5.2", - "async.util.onlyonce": "0.5.2", - "async.util.setimmediate": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "eachofseries" - ] -} diff --git a/lib/eachseries/.editorconfig b/lib/eachseries/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/eachseries/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/eachseries/.gitignore b/lib/eachseries/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/eachseries/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/eachseries/.jscsrc b/lib/eachseries/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/eachseries/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/eachseries/.jshintrc b/lib/eachseries/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/eachseries/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/eachseries/README.md b/lib/eachseries/README.md deleted file mode 100644 index 47c1e1b..0000000 --- a/lib/eachseries/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.eachseries - - -[](https://david-dm.org/async-js/async.eachseries) -[](https://david-dm.org/async-js/async.eachseries#info=devDependencies) -[](https://www.npmjs.org/package/async.eachseries) -[](https://paypal.me/kikobeats) - -> [async#eachseries](https://github.com/async-js/async#async.eachseries) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/eachseries/index.js b/lib/eachseries/index.js deleted file mode 100644 index 6cbdb7f..0000000 --- a/lib/eachseries/index.js +++ /dev/null @@ -1,8 +0,0 @@ -'use strict'; - -var eachOfSeries = require('async.eachofseries'); -var withoutIndex = require('async.util.withoutindex'); - -module.exports = function eachSeries(arr, iterator, cb) { - return eachOfSeries(arr, withoutIndex(iterator), cb); -}; diff --git a/lib/eachseries/package.json b/lib/eachseries/package.json deleted file mode 100644 index c7e9e64..0000000 --- a/lib/eachseries/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.eachseries", - "description": "async eachseriesmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachofseries": "0.5.2", - "async.util.withoutindex": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "eachseries" - ] -} diff --git a/lib/ensureAsync.js b/lib/ensureAsync.js new file mode 100644 index 0000000..66de26b --- /dev/null +++ b/lib/ensureAsync.js @@ -0,0 +1,24 @@ +'use strict'; + +import restParam from 'lodash/function/restParam'; + +import setImmediate from './internal/setImmediate'; + +export default function ensureAsync(fn) { + return restParam(function (args) { + var callback = args.pop(); + args.push(function () { + var innerArgs = arguments; + if (sync) { + setImmediate(function () { + callback.apply(null, innerArgs); + }); + } else { + callback.apply(null, innerArgs); + } + }); + var sync = true; + fn.apply(this, args); + sync = false; + }); +} diff --git a/lib/ensureasync/.editorconfig b/lib/ensureasync/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/ensureasync/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/ensureasync/.gitignore b/lib/ensureasync/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/ensureasync/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/ensureasync/.jscsrc b/lib/ensureasync/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/ensureasync/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/ensureasync/.jshintrc b/lib/ensureasync/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/ensureasync/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/ensureasync/README.md b/lib/ensureasync/README.md deleted file mode 100644 index a3ce8bf..0000000 --- a/lib/ensureasync/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.ensureasync - - -[](https://david-dm.org/async-js/async.ensureasync) -[](https://david-dm.org/async-js/async.ensureasync#info=devDependencies) -[](https://www.npmjs.org/package/async.ensureasync) -[](https://paypal.me/kikobeats) - -> [async#ensureasync](https://github.com/async-js/async#async.ensureasync) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/ensureasync/index.js b/lib/ensureasync/index.js deleted file mode 100644 index 0155da3..0000000 --- a/lib/ensureasync/index.js +++ /dev/null @@ -1,2 +0,0 @@ -'use strict'; -module.exports = require('async.util.ensureasync'); diff --git a/lib/ensureasync/package.json b/lib/ensureasync/package.json deleted file mode 100644 index 9e18b2e..0000000 --- a/lib/ensureasync/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.ensureasync", - "description": "async ensureasyncmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.ensureasync": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "ensureasync" - ] -} diff --git a/lib/every.js b/lib/every.js new file mode 100644 index 0000000..7ee3713 --- /dev/null +++ b/lib/every.js @@ -0,0 +1,7 @@ +'use strict'; + +import createTester from './internal/createTester'; +import eachOf from './eachOf'; +import notId from './internal/notId'; + +export default createTester(eachOf, notId, notId); diff --git a/lib/every/.editorconfig b/lib/every/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/every/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/every/.gitignore b/lib/every/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/every/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/every/.jscsrc b/lib/every/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/every/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/every/.jshintrc b/lib/every/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/every/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/every/README.md b/lib/every/README.md deleted file mode 100644 index ddbd59f..0000000 --- a/lib/every/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.every - - -[](https://david-dm.org/async-js/async.every) -[](https://david-dm.org/async-js/async.every#info=devDependencies) -[](https://www.npmjs.org/package/async.every) -[](https://paypal.me/kikobeats) - -> [async#every](https://github.com/async-js/async#async.every) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/every/index.js b/lib/every/index.js deleted file mode 100644 index f348ddf..0000000 --- a/lib/every/index.js +++ /dev/null @@ -1,7 +0,0 @@ -'use strict'; - -var eachOf = require('async.eachof'); -var notId = require('async.util.notid'); -var createTester = require('async.util.createtester'); - -module.exports = createTester(eachOf, notId, notId); diff --git a/lib/every/package.json b/lib/every/package.json deleted file mode 100644 index 512ec16..0000000 --- a/lib/every/package.json +++ /dev/null @@ -1,22 +0,0 @@ -{ - "name": "async.every", - "description": "async everymethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachof": "0.5.2", - "async.util.createtester": "0.5.2", - "async.util.notid": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "every" - ] -} diff --git a/lib/everyLimit.js b/lib/everyLimit.js new file mode 100644 index 0000000..4b3fc5f --- /dev/null +++ b/lib/everyLimit.js @@ -0,0 +1,7 @@ +'use strict'; + +import createTester from './internal/createTester'; +import eachOfLimit from './eachOfLimit'; +import notId from './internal/notId'; + +export default createTester(eachOfLimit, notId, notId); diff --git a/lib/everylimit/.editorconfig b/lib/everylimit/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/everylimit/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/everylimit/.gitignore b/lib/everylimit/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/everylimit/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/everylimit/.jscsrc b/lib/everylimit/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/everylimit/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/everylimit/.jshintrc b/lib/everylimit/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/everylimit/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/everylimit/README.md b/lib/everylimit/README.md deleted file mode 100644 index 69bfa8d..0000000 --- a/lib/everylimit/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.everylimit - - -[](https://david-dm.org/async-js/async.everylimit) -[](https://david-dm.org/async-js/async.everylimit#info=devDependencies) -[](https://www.npmjs.org/package/async.everylimit) -[](https://paypal.me/kikobeats) - -> [async#everylimit](https://github.com/async-js/async#async.everylimit) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/everylimit/index.js b/lib/everylimit/index.js deleted file mode 100644 index 728c75a..0000000 --- a/lib/everylimit/index.js +++ /dev/null @@ -1,7 +0,0 @@ -'use strict'; - -var eachOfLimit = require('async.eachoflimit'); -var notId = require('async.util.notid'); -var createTester = require('async.util.createtester'); - -module.exports = createTester(eachOfLimit, notId, notId); diff --git a/lib/everylimit/package.json b/lib/everylimit/package.json deleted file mode 100644 index 475fab1..0000000 --- a/lib/everylimit/package.json +++ /dev/null @@ -1,22 +0,0 @@ -{ - "name": "async.everylimit", - "description": "async everylimitmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachoflimit": "0.5.2", - "async.util.createtester": "0.5.2", - "async.util.notid": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "everylimit" - ] -} diff --git a/lib/filter.js b/lib/filter.js new file mode 100644 index 0000000..36af2b1 --- /dev/null +++ b/lib/filter.js @@ -0,0 +1,6 @@ +'use strict'; + +import filter from './internal/filter'; +import doParallel from './internal/doParallel'; + +export default doParallel(filter); diff --git a/lib/filter/.editorconfig b/lib/filter/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/filter/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/filter/.gitignore b/lib/filter/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/filter/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/filter/.jscsrc b/lib/filter/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/filter/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/filter/.jshintrc b/lib/filter/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/filter/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/filter/README.md b/lib/filter/README.md deleted file mode 100644 index 541dd42..0000000 --- a/lib/filter/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.filter - - -[](https://david-dm.org/async-js/async.filter) -[](https://david-dm.org/async-js/async.filter#info=devDependencies) -[](https://www.npmjs.org/package/async.filter) -[](https://paypal.me/kikobeats) - -> [async#filter](https://github.com/async-js/async#async.filter) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/filter/index.js b/lib/filter/index.js deleted file mode 100644 index d949d3d..0000000 --- a/lib/filter/index.js +++ /dev/null @@ -1,4 +0,0 @@ -'use strict'; -var filter = require('async.util.filter'); -var doParallel = require('async.util.doparallel'); -module.exports = doParallel(filter); diff --git a/lib/filter/package.json b/lib/filter/package.json deleted file mode 100644 index bbbe460..0000000 --- a/lib/filter/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.filter", - "description": "async filtermethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.doparallel": "0.5.2", - "async.util.filter": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "filter" - ] -} diff --git a/lib/filterLimit.js b/lib/filterLimit.js new file mode 100644 index 0000000..8fe237f --- /dev/null +++ b/lib/filterLimit.js @@ -0,0 +1,6 @@ +'use strict'; + +import filter from './internal/filter'; +import doParallelLimit from './internal/doParallelLimit'; + +export default doParallelLimit(filter); diff --git a/lib/filterSeries.js b/lib/filterSeries.js new file mode 100644 index 0000000..861ca8b --- /dev/null +++ b/lib/filterSeries.js @@ -0,0 +1,6 @@ +'use strict'; + +import filter from './internal/filter'; +import doSeries from './internal/doSeries'; + +export default doSeries(filter); diff --git a/lib/filterlimit/.editorconfig b/lib/filterlimit/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/filterlimit/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/filterlimit/.gitignore b/lib/filterlimit/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/filterlimit/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/filterlimit/.jscsrc b/lib/filterlimit/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/filterlimit/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/filterlimit/.jshintrc b/lib/filterlimit/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/filterlimit/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/filterlimit/README.md b/lib/filterlimit/README.md deleted file mode 100644 index cc9162c..0000000 --- a/lib/filterlimit/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.filterlimit - - -[](https://david-dm.org/async-js/async.filterlimit) -[](https://david-dm.org/async-js/async.filterlimit#info=devDependencies) -[](https://www.npmjs.org/package/async.filterlimit) -[](https://paypal.me/kikobeats) - -> [async#filterlimit](https://github.com/async-js/async#async.filterlimit) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/filterlimit/index.js b/lib/filterlimit/index.js deleted file mode 100644 index 7161d3f..0000000 --- a/lib/filterlimit/index.js +++ /dev/null @@ -1,4 +0,0 @@ -'use strict'; -var filter = require('async.util.filter'); -var doParallelLimit = require('async.util.doparallellimit'); -module.exports = doParallelLimit(filter); diff --git a/lib/filterlimit/package.json b/lib/filterlimit/package.json deleted file mode 100644 index 502b04d..0000000 --- a/lib/filterlimit/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.filterlimit", - "description": "async filterlimitmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.doparallellimit": "0.5.2", - "async.util.filter": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "filterlimit" - ] -} diff --git a/lib/filterseries/.editorconfig b/lib/filterseries/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/filterseries/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/filterseries/.gitignore b/lib/filterseries/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/filterseries/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/filterseries/.jscsrc b/lib/filterseries/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/filterseries/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/filterseries/.jshintrc b/lib/filterseries/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/filterseries/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/filterseries/README.md b/lib/filterseries/README.md deleted file mode 100644 index e6a6e06..0000000 --- a/lib/filterseries/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.filterseries - - -[](https://david-dm.org/async-js/async.filterseries) -[](https://david-dm.org/async-js/async.filterseries#info=devDependencies) -[](https://www.npmjs.org/package/async.filterseries) -[](https://paypal.me/kikobeats) - -> [async#filterseries](https://github.com/async-js/async#async.filterseries) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/filterseries/index.js b/lib/filterseries/index.js deleted file mode 100644 index b092b80..0000000 --- a/lib/filterseries/index.js +++ /dev/null @@ -1,6 +0,0 @@ -'use strict'; - -var filter = require('async.util.filter'); -var doSeries = require('async.util.doseries'); - -module.exports = doSeries(filter); diff --git a/lib/filterseries/package.json b/lib/filterseries/package.json deleted file mode 100644 index 955143c..0000000 --- a/lib/filterseries/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.filterseries", - "description": "async filterseriesmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.doseries": "0.5.2", - "async.util.filter": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "filterseries" - ] -} diff --git a/lib/forever.js b/lib/forever.js new file mode 100644 index 0000000..95f0d5d --- /dev/null +++ b/lib/forever.js @@ -0,0 +1,15 @@ +import noop from 'lodash/utility/noop'; + +import onlyOnce from './internal/onlyOnce'; +import ensureAsync from './ensureAsync'; + +export default function forever(fn, cb) { + var done = onlyOnce(cb || noop); + var task = ensureAsync(fn); + + function next(err) { + if (err) return done(err); + task(next); + } + next(); +} diff --git a/lib/forever/.editorconfig b/lib/forever/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/forever/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/forever/.gitignore b/lib/forever/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/forever/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/forever/.jscsrc b/lib/forever/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/forever/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/forever/.jshintrc b/lib/forever/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/forever/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/forever/README.md b/lib/forever/README.md deleted file mode 100644 index 0c69ae2..0000000 --- a/lib/forever/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.forever - - -[](https://david-dm.org/async-js/async.forever) -[](https://david-dm.org/async-js/async.forever#info=devDependencies) -[](https://www.npmjs.org/package/async.forever) -[](https://paypal.me/kikobeats) - -> [async#forever](https://github.com/async-js/async#async.forever) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/forever/index.js b/lib/forever/index.js deleted file mode 100644 index 25dd70b..0000000 --- a/lib/forever/index.js +++ /dev/null @@ -1,14 +0,0 @@ -var noop = require('async.util.noop'); -var onlyOnce = require('async.util.onlyonce'); -var ensureAsync = require('async.util.ensureasync'); - -module.exports = function forever(fn, cb) { - var done = onlyOnce(cb || noop); - var task = ensureAsync(fn); - - function next(err) { - if (err) return done(err); - task(next); - } - next(); -}; diff --git a/lib/forever/package.json b/lib/forever/package.json deleted file mode 100644 index 32881c5..0000000 --- a/lib/forever/package.json +++ /dev/null @@ -1,22 +0,0 @@ -{ - "name": "async.forever", - "description": "async forevermethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.ensureasync": "0.5.2", - "async.util.noop": "0.5.2", - "async.util.onlyonce": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "forever" - ] -} diff --git a/lib/index.js b/lib/index.js index 2ed83a6..745090b 100644 --- a/lib/index.js +++ b/lib/index.js @@ -1,132 +1,83 @@ 'use strict'; -var async = {}; +export {default as applyEach} from './applyEach'; +export {default as applyEachSeries} from './applyEachSeries'; +export {default as apply} from './apply'; +export {default as asyncify} from './asyncify'; +export {default as auto} from './auto'; +export {default as cargo} from './cargo'; +export {default as compose} from './compose'; +export {default as concat} from './concat'; +export {default as concatSeries} from './concatSeries'; +export {default as constant} from './constant'; +export {default as detect} from './detect'; +export {default as detectLimit} from './detectLimit'; +export {default as detectSeries} from './detectSeries'; +export {default as dir} from './dir'; +export {default as doDuring} from './doDuring'; +export {default as doUntil} from './doUntil'; +export {default as doWhilst} from './doWhilst'; +export {default as during} from './during'; +export {default as each} from './each'; +export {default as eachLimit} from './eachLimit'; +export {default as eachOf} from './eachOf'; +export {default as eachOfLimit} from './eachOfLimit'; +export {default as eachOfSeries} from './eachOfSeries'; +export {default as eachSeries} from './eachSeries'; +export {default as ensureAsync} from './ensureAsync'; +export {default as every} from './every'; +export {default as everyLimit} from './everyLimit'; +export {default as filter} from './filter'; +export {default as filterLimit} from './filterLimit'; +export {default as filterSeries} from './filterSeries'; +export {default as forever} from './forever'; +export {default as index} from './index'; +export {default as iterator} from './iterator'; +export {default as log} from './log'; +export {default as map} from './map'; +export {default as mapLimit} from './mapLimit'; +export {default as mapSeries} from './mapSeries'; +export {default as memoize} from './memoize'; +export {default as nextTick} from './nextTick'; +export {default as parallel} from './parallel'; +export {default as parallelLimit} from './parallelLimit'; +export {default as priorityQueue} from './priorityQueue'; +export {default as queue} from './queue'; +export {default as reduce} from './reduce'; +export {default as reduceRight} from './reduceRight'; +export {default as reject} from './reject'; +export {default as rejectLimit} from './rejectLimit'; +export {default as rejectSeries} from './rejectSeries'; +export {default as retry} from './retry'; +export {default as seq} from './seq'; +export {default as series} from './series'; +export {default as setImmediate} from './setImmediate'; +export {default as some} from './some'; +export {default as someLimit} from './someLimit'; +export {default as sortBy} from './sortBy'; +export {default as times} from './times'; +export {default as timesLimit} from './timesLimit'; +export {default as timesSeries} from './timesSeries'; +export {default as transform} from './transform'; +export {default as unmemoize} from './unmemoize'; +export {default as until} from './until'; +export {default as waterfall} from './waterfall'; +export {default as whilst} from './whilst'; + +// Aliases +export {default as all} from './every'; +export {default as any} from './some'; +export {default as forEach} from './each'; +export {default as forEachSeries} from './eachSeries'; +export {default as forEachLimit} from './eachLimit'; +export {default as forEachOf} from './eachOf'; +export {default as forEachOfSeries} from './eachOfSeries'; +export {default as forEachOfLimit} from './eachOfLimit'; +export {default as inject} from './reduce'; +export {default as foldl} from './reduce'; +export {default as foldr} from './reduceRight'; +export {default as select} from './filter'; +export {default as selectLimit} from './filterLimit'; +export {default as selectSeries} from './filterSeries'; +export {default as wrapSync} from './asyncify'; -async.nextTick = require('async.nexttick'); -async.setImmediate = require('async.setimmediate'); - -async.forEach = -async.each = require('async.each'); - -async.forEachSeries = -async.eachSeries = require('async.eachseries'); - -async.forEachLimit = -async.eachLimit = require('async.eachlimit'); - -async.forEachOf = -async.eachOf = require('async.eachof'); - -async.forEachOfSeries = -async.eachOfSeries = require('async.eachofseries'); - -async.forEachOfLimit = -async.eachOfLimit = require('async.eachoflimit'); - -async.map = require('async.map'); -async.mapSeries = require('async.mapseries'); -async.mapLimit = require('async.maplimit'); - -async.inject = -async.foldl = -async.reduce = require('async.reduce'); - -async.foldr = -async.reduceRight = require('async.reduceright'); - -async.transform = require('async.transform'); - -async.select = -async.filter = require('async.filter'); - -async.selectLimit = -async.filterLimit = require('async.filterlimit'); - -async.selectSeries = -async.filterSeries = require('async.filterseries'); - -async.reject = require('async.reject'); -async.rejectLimit = require('async.rejectlimit'); -async.rejectSeries = require('async.rejectseries'); - -async.any = -async.some = require('async.some'); - -async.someLimit = require('async.somelimit'); - -async.all = -async.every = require('async.every'); - -async.everyLimit = require('async.everylimit'); - -async.detect = require('async.detect'); -async.detectSeries = require('async.detectseries'); -async.detectLimit = require('async.detectlimit'); - -async.sortBy = require('async.sortby'); - -async.auto = require('async.auto'); - -async.retry = require('async.retry'); - -async.waterfall = require('async.waterfall'); - -async.parallel = require('async.parallel'); - -async.parallelLimit = require('async.parallellimit'); - -async.series = require('async.series'); - -async.iterator = require('async.iterator'); - -async.apply = require('async.apply'); - -async.concat = require('async.concat'); -async.concatSeries = require('async.concatseries'); - -async.whilst = require('async.whilst'); - -async.doWhilst = require('async.dowhilst'); - -async.until = require('async.until'); - -async.doUntil = require('async.dountil'); - -async.during = require('async.during'); - -async.doDuring = require('async.doduring'); - -async.queue = require('async.queue'); - -async.priorityQueue = require('async.priorityqueue'); - -async.cargo = require('async.cargo'); - -async.log = require('async.log'); -async.dir = require('async.dir'); - -async.memoize = require('async.memoize'); - -async.unmemoize = require('async.unmemoize'); - -async.times = require('async.times'); -async.timesSeries = require('async.timesseries'); -async.timesLimit = require('async.timeslimit'); - -async.seq = require('async.seq'); - -async.compose = require('async.compose'); - -async.applyEach = require('async.applyeach'); -async.applyEachSeries = require('async.applyeachseries'); - -async.forever = require('async.forever'); - -async.ensureAsync = require('async.ensureasync'); - -async.constant = require('async.constant'); - -async.wrapSync = -async.asyncify = require('async.asyncify'); - -module.exports = async; diff --git a/lib/internal/applyEach.js b/lib/internal/applyEach.js new file mode 100644 index 0000000..62eadfd --- /dev/null +++ b/lib/internal/applyEach.js @@ -0,0 +1,20 @@ +import restParam from 'lodash/function/restParam'; + +export default function _applyEach(eachfn) { + return restParam(function(fns, args) { + var go = restParam(function(args) { + var that = this; + var callback = args.pop(); + return eachfn(fns, function (fn, _, cb) { + fn.apply(that, args.concat([cb])); + }, + callback); + }); + if (args.length) { + return go.apply(this, args); + } + else { + return go; + } + }); +} diff --git a/lib/internal/concat.js b/lib/internal/concat.js new file mode 100644 index 0000000..a55de2e --- /dev/null +++ b/lib/internal/concat.js @@ -0,0 +1,11 @@ +export default function concat(eachfn, arr, fn, callback) { + var result = []; + eachfn(arr, function (x, index, cb) { + fn(x, function (err, y) { + result = result.concat(y || []); + cb(err); + }); + }, function (err) { + callback(err, result); + }); +} diff --git a/lib/internal/consoleFunc.js b/lib/internal/consoleFunc.js new file mode 100644 index 0000000..d2baebd --- /dev/null +++ b/lib/internal/consoleFunc.js @@ -0,0 +1,21 @@ +import arrayEach from 'lodash/internal/arrayEach'; +import restParam from 'lodash/function/restParam'; + +export default function consoleFunc(name) { + return restParam(function (fn, args) { + fn.apply(null, args.concat([restParam(function (err, args) { + if (typeof console === 'object') { + if (err) { + if (console.error) { + console.error(err); + } + } + else if (console[name]) { + arrayEach(args, function (x) { + console[name](x); + }); + } + } + })])); + }); +} diff --git a/lib/internal/createTester.js b/lib/internal/createTester.js new file mode 100644 index 0000000..3dbf78d --- /dev/null +++ b/lib/internal/createTester.js @@ -0,0 +1,24 @@ +export default function _createTester(eachfn, check, getResult) { + return function(arr, limit, iterator, cb) { + function done() { + if (cb) cb(getResult(false, void 0)); + } + function iteratee(x, _, callback) { + if (!cb) return callback(); + iterator(x, function (v) { + if (cb && check(v)) { + cb(getResult(true, x)); + cb = iterator = false; + } + callback(); + }); + } + if (arguments.length > 3) { + eachfn(arr, limit, iteratee, done); + } else { + cb = iterator; + iterator = limit; + eachfn(arr, iteratee, done); + } + }; +} diff --git a/lib/internal/doParallel.js b/lib/internal/doParallel.js new file mode 100644 index 0000000..fdb1264 --- /dev/null +++ b/lib/internal/doParallel.js @@ -0,0 +1,7 @@ +import eachOf from '../eachOf'; + +export default function doParallel(fn) { + return function (obj, iterator, callback) { + return fn(eachOf, obj, iterator, callback); + }; +} diff --git a/lib/internal/doParallelLimit.js b/lib/internal/doParallelLimit.js new file mode 100644 index 0000000..e5d04f4 --- /dev/null +++ b/lib/internal/doParallelLimit.js @@ -0,0 +1,7 @@ +import eachOfLimit from './eachOfLimit'; + +export default function doParallelLimit(fn) { + return function (obj, limit, iterator, callback) { + return fn(eachOfLimit(limit), obj, iterator, callback); + }; +} diff --git a/lib/internal/doSeries.js b/lib/internal/doSeries.js new file mode 100644 index 0000000..1724798 --- /dev/null +++ b/lib/internal/doSeries.js @@ -0,0 +1,7 @@ +import eachOfSeries from '../eachOfSeries'; + +export default function doSeries(fn) { + return function (obj, iterator, callback) { + return fn(eachOfSeries, obj, iterator, callback); + }; +} diff --git a/lib/internal/eachOfLimit.js b/lib/internal/eachOfLimit.js new file mode 100644 index 0000000..2ef8f88 --- /dev/null +++ b/lib/internal/eachOfLimit.js @@ -0,0 +1,47 @@ +import noop from 'lodash/utility/noop'; +import once from 'lodash/function/once'; + +import keyIterator from './keyIterator'; +import onlyOnce from './onlyOnce'; + +export default function _eachOfLimit(limit) { + return function (obj, iterator, callback) { + callback = once(callback || noop); + obj = obj || []; + var nextKey = keyIterator(obj); + if (limit <= 0) { + return callback(null); + } + var done = false; + var running = 0; + var errored = false; + + (function replenish () { + if (done && running <= 0) { + return callback(null); + } + + while (running < limit && !errored) { + var key = nextKey(); + if (key === null) { + done = true; + if (running <= 0) { + callback(null); + } + return; + } + running += 1; + iterator(obj[key], key, onlyOnce(function (err) { + running -= 1; + if (err) { + callback(err); + errored = true; + } + else { + replenish(); + } + })); + } + })(); + }; +} diff --git a/lib/internal/filter.js b/lib/internal/filter.js new file mode 100644 index 0000000..3355bee --- /dev/null +++ b/lib/internal/filter.js @@ -0,0 +1,18 @@ +import arrayMap from 'lodash/internal/arrayMap'; +import property from 'lodash/utility/property'; + +export default function _filter(eachfn, arr, iterator, callback) { + var results = []; + eachfn(arr, function (x, index, callback) { + iterator(x, function (v) { + if (v) { + results.push({index: index, value: x}); + } + callback(); + }); + }, function () { + callback(arrayMap(results.sort(function (a, b) { + return a.index - b.index; + }), property('value'))); + }); +} diff --git a/lib/internal/findGetResult.js b/lib/internal/findGetResult.js new file mode 100644 index 0000000..7345df6 --- /dev/null +++ b/lib/internal/findGetResult.js @@ -0,0 +1,3 @@ +export default function _findGetResult(v, x) { + return x; +} diff --git a/lib/internal/keyIterator.js b/lib/internal/keyIterator.js new file mode 100644 index 0000000..801b43b --- /dev/null +++ b/lib/internal/keyIterator.js @@ -0,0 +1,21 @@ +import isArrayLike from 'lodash/internal/isArrayLike'; +import keys from 'lodash/object/keys'; + +export default function keyIterator(coll) { + var i = -1; + var len; + if (isArrayLike(coll)) { + len = coll.length; + return function next() { + i++; + return i < len ? i : null; + }; + } else { + var okeys = keys(coll); + len = okeys.length; + return function next() { + i++; + return i < len ? okeys[i] : null; + }; + } +} diff --git a/lib/internal/map.js b/lib/internal/map.js new file mode 100644 index 0000000..aa4fdc1 --- /dev/null +++ b/lib/internal/map.js @@ -0,0 +1,17 @@ +import isArrayLike from 'lodash/internal/isArrayLike'; +import noop from 'lodash/utility/noop'; +import once from 'lodash/function/once'; + +export default function _asyncMap(eachfn, arr, iterator, callback) { + callback = once(callback || noop); + arr = arr || []; + var results = isArrayLike(arr) ? [] : {}; + eachfn(arr, function (value, index, callback) { + iterator(value, function (err, v) { + results[index] = v; + callback(err); + }); + }, function (err) { + callback(err, results); + }); +} diff --git a/lib/internal/notId.js b/lib/internal/notId.js new file mode 100644 index 0000000..65a676e --- /dev/null +++ b/lib/internal/notId.js @@ -0,0 +1,3 @@ +export default function notId(v) { + return !v; +} diff --git a/lib/internal/onlyOnce.js b/lib/internal/onlyOnce.js new file mode 100644 index 0000000..0a0f278 --- /dev/null +++ b/lib/internal/onlyOnce.js @@ -0,0 +1,7 @@ +export default function onlyOnce(fn) { + return function() { + if (fn === null) throw new Error("Callback was already called."); + fn.apply(this, arguments); + fn = null; + }; +} diff --git a/lib/internal/parallel.js b/lib/internal/parallel.js new file mode 100644 index 0000000..5d959ba --- /dev/null +++ b/lib/internal/parallel.js @@ -0,0 +1,21 @@ +import noop from 'lodash/utility/noop'; +import isArrayLike from 'lodash/internal/isArrayLike'; +import restParam from 'lodash/function/restParam'; + + +export default function _parallel(eachfn, tasks, callback) { + callback = callback || noop; + var results = isArrayLike(tasks) ? [] : {}; + + eachfn(tasks, function (task, key, callback) { + task(restParam(function (err, args) { + if (args.length <= 1) { + args = args[0]; + } + results[key] = args; + callback(err); + })); + }, function (err) { + callback(err, results); + }); +} diff --git a/lib/internal/queue.js b/lib/internal/queue.js new file mode 100644 index 0000000..71c6c64 --- /dev/null +++ b/lib/internal/queue.js @@ -0,0 +1,138 @@ +import arrayEach from 'lodash/internal/arrayEach'; +import arrayMap from 'lodash/internal/arrayMap'; +import isArray from 'lodash/lang/isArray'; +import noop from 'lodash/utility/noop'; +import property from 'lodash/utility/property'; + +import onlyOnce from './onlyOnce'; +import setImmediate from './setImmediate'; + +export default function queue(worker, concurrency, payload) { + if (concurrency == null) { + concurrency = 1; + } + else if(concurrency === 0) { + throw new Error('Concurrency must not be zero'); + } + function _insert(q, data, pos, callback) { + if (callback != null && typeof callback !== 'function') { + throw new Error('task callback must be a function'); + } + q.started = true; + if (!isArray(data)) { + data = [data]; + } + if(data.length === 0 && q.idle()) { + // call drain immediately if there are no tasks + return setImmediate(function() { + q.drain(); + }); + } + arrayEach(data, function(task) { + var item = { + data: task, + callback: callback || noop + }; + + if (pos) { + q.tasks.unshift(item); + } else { + q.tasks.push(item); + } + + if (q.tasks.length === q.concurrency) { + q.saturated(); + } + }); + setImmediate(q.process); + } + function _next(q, tasks) { + return function(){ + workers -= 1; + + var removed = false; + var args = arguments; + arrayEach(tasks, function (task) { + arrayEach(workersList, function (worker, index) { + if (worker === task && !removed) { + workersList.splice(index, 1); + removed = true; + } + }); + + task.callback.apply(task, args); + }); + if (q.tasks.length + workers === 0) { + q.drain(); + } + q.process(); + }; + } + + var workers = 0; + var workersList = []; + var q = { + tasks: [], + concurrency: concurrency, + payload: payload, + saturated: noop, + empty: noop, + drain: noop, + started: false, + paused: false, + push: function (data, callback) { + _insert(q, data, false, callback); + }, + kill: function () { + q.drain = noop; + q.tasks = []; + }, + unshift: function (data, callback) { + _insert(q, data, true, callback); + }, + process: function () { + while(!q.paused && workers < q.concurrency && q.tasks.length){ + + var tasks = q.payload ? + q.tasks.splice(0, q.payload) : + q.tasks.splice(0, q.tasks.length); + + var data = arrayMap(tasks, property('data')); + + if (q.tasks.length === 0) { + q.empty(); + } + workers += 1; + workersList.push(tasks[0]); + var cb = onlyOnce(_next(q, tasks)); + worker(data, cb); + } + }, + length: function () { + return q.tasks.length; + }, + running: function () { + return workers; + }, + workersList: function () { + return workersList; + }, + idle: function() { + return q.tasks.length + workers === 0; + }, + pause: function () { + q.paused = true; + }, + resume: function () { + if (q.paused === false) { return; } + q.paused = false; + var resumeCount = Math.min(q.concurrency, q.tasks.length); + // Need to call q.process once per concurrent + // worker to preserve full concurrency after pause + for (var w = 1; w <= resumeCount; w++) { + setImmediate(q.process); + } + } + }; + return q; +} diff --git a/lib/internal/reject.js b/lib/internal/reject.js new file mode 100644 index 0000000..b15fab1 --- /dev/null +++ b/lib/internal/reject.js @@ -0,0 +1,9 @@ +import filter from './filter'; + +export default function reject(eachfn, arr, iterator, callback) { + filter(eachfn, arr, function(value, cb) { + iterator(value, function(v) { + cb(!v); + }); + }, callback); +} diff --git a/lib/internal/setImmediate.js b/lib/internal/setImmediate.js new file mode 100644 index 0000000..d44c66e --- /dev/null +++ b/lib/internal/setImmediate.js @@ -0,0 +1,17 @@ +var _setImmediate = typeof setImmediate === 'function' && setImmediate; + +var _delay; +if (_setImmediate) { + _delay = function(fn) { + // not a direct alias for IE10 compatibility + _setImmediate(fn); + } +} else if (typeof process === 'object' && typeof process.nextTick === 'function') { + _delay = process.nextTick; +} else { + _delay = function(fn) { + setTimeout(fn, 0); + }; +} + +export default _delay; diff --git a/lib/internal/withoutIndex.js b/lib/internal/withoutIndex.js new file mode 100644 index 0000000..706c27a --- /dev/null +++ b/lib/internal/withoutIndex.js @@ -0,0 +1,5 @@ +export default function _withoutIndex(iterator) { + return function (value, index, callback) { + return iterator(value, callback); + }; +} diff --git a/lib/iterator/index.js b/lib/iterator.js index 459ed84..568171a 100644 --- a/lib/iterator/index.js +++ b/lib/iterator.js @@ -1,6 +1,6 @@ 'use strict'; -module.exports = function(tasks) { +export default function(tasks) { function makeCallback(index) { function fn() { if (tasks.length) { @@ -14,4 +14,4 @@ module.exports = function(tasks) { return fn; } return makeCallback(0); -}; +} diff --git a/lib/iterator/.editorconfig b/lib/iterator/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/iterator/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/iterator/.gitignore b/lib/iterator/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/iterator/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/iterator/.jscsrc b/lib/iterator/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/iterator/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/iterator/.jshintrc b/lib/iterator/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/iterator/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/iterator/README.md b/lib/iterator/README.md deleted file mode 100644 index 2f6b806..0000000 --- a/lib/iterator/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.iterator - - -[](https://david-dm.org/async-js/async.iterator) -[](https://david-dm.org/async-js/async.iterator#info=devDependencies) -[](https://www.npmjs.org/package/async.iterator) -[](https://paypal.me/kikobeats) - -> [async#iterator](https://github.com/async-js/async#async.iterator) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/iterator/package.json b/lib/iterator/package.json deleted file mode 100644 index 6960270..0000000 --- a/lib/iterator/package.json +++ /dev/null @@ -1,17 +0,0 @@ -{ - "name": "async.iterator", - "description": "async iteratormethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "keywords": [ - "async", - "async-modularized", - "iterator" - ] -} diff --git a/lib/log.js b/lib/log.js new file mode 100644 index 0000000..892c91f --- /dev/null +++ b/lib/log.js @@ -0,0 +1,2 @@ +'use strict'; +export default require('async.util.consolefn')('log'); diff --git a/lib/log/.editorconfig b/lib/log/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/log/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/log/.gitignore b/lib/log/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/log/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/log/.jscsrc b/lib/log/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/log/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/log/.jshintrc b/lib/log/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/log/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/log/README.md b/lib/log/README.md deleted file mode 100644 index a5f6b63..0000000 --- a/lib/log/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.log - - -[](https://david-dm.org/async-js/async.log) -[](https://david-dm.org/async-js/async.log#info=devDependencies) -[](https://www.npmjs.org/package/async.log) -[](https://paypal.me/kikobeats) - -> [async#log](https://github.com/async-js/async#async.log) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/log/index.js b/lib/log/index.js deleted file mode 100644 index 0cffb89..0000000 --- a/lib/log/index.js +++ /dev/null @@ -1,2 +0,0 @@ -'use strict'; -module.exports = require('async.util.consolefn')('log'); diff --git a/lib/log/package.json b/lib/log/package.json deleted file mode 100644 index 473cdbf..0000000 --- a/lib/log/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.log", - "description": "async logmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.consolefn": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "log" - ] -} diff --git a/lib/map/index.js b/lib/map.js index 2609ff8..9a02059 100644 --- a/lib/map/index.js +++ b/lib/map.js @@ -1,4 +1,4 @@ 'use strict'; var mapAsync = require('async.util.mapasync'); var doParallel = require('async.util.doparallel'); -module.exports = doParallel(mapAsync); +export default doParallel(mapAsync); diff --git a/lib/map/.editorconfig b/lib/map/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/map/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/map/.gitignore b/lib/map/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/map/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/map/.jscsrc b/lib/map/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/map/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/map/.jshintrc b/lib/map/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/map/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/map/README.md b/lib/map/README.md deleted file mode 100644 index 42f5159..0000000 --- a/lib/map/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.map - - -[](https://david-dm.org/async-js/async.map) -[](https://david-dm.org/async-js/async.map#info=devDependencies) -[](https://www.npmjs.org/package/async.map) -[](https://paypal.me/kikobeats) - -> [async#map](https://github.com/async-js/async#async.map) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/map/package.json b/lib/map/package.json deleted file mode 100644 index 53a51ef..0000000 --- a/lib/map/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.map", - "description": "async mapmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.doparallel": "0.5.2", - "async.util.mapasync": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "map" - ] -} diff --git a/lib/mapLimit.js b/lib/mapLimit.js new file mode 100644 index 0000000..642b4c6 --- /dev/null +++ b/lib/mapLimit.js @@ -0,0 +1,6 @@ +'use strict'; + +import doParallelLimit from './internal/doParallelLimit'; +import map from './internal/map'; + +export default doParallelLimit(map); diff --git a/lib/mapSeries.js b/lib/mapSeries.js new file mode 100644 index 0000000..bfcdaa2 --- /dev/null +++ b/lib/mapSeries.js @@ -0,0 +1,6 @@ +'use strict'; + +import map from './internal/map'; +import doSeries from './internal/doSeries'; + +export default doSeries(map); diff --git a/lib/maplimit/.editorconfig b/lib/maplimit/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/maplimit/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/maplimit/.gitignore b/lib/maplimit/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/maplimit/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/maplimit/.jscsrc b/lib/maplimit/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/maplimit/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/maplimit/.jshintrc b/lib/maplimit/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/maplimit/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/maplimit/README.md b/lib/maplimit/README.md deleted file mode 100644 index 7bbec8f..0000000 --- a/lib/maplimit/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.maplimit - - -[](https://david-dm.org/async-js/async.maplimit) -[](https://david-dm.org/async-js/async.maplimit#info=devDependencies) -[](https://www.npmjs.org/package/async.maplimit) -[](https://paypal.me/kikobeats) - -> [async#maplimit](https://github.com/async-js/async#async.maplimit) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/maplimit/index.js b/lib/maplimit/index.js deleted file mode 100644 index 3c60802..0000000 --- a/lib/maplimit/index.js +++ /dev/null @@ -1,6 +0,0 @@ -'use strict'; -var mapAsync = require('async.util.mapasync'); -var doParallelLimit = require('async.util.doparallellimit'); -module.exports = doParallelLimit(mapAsync); - - diff --git a/lib/maplimit/package.json b/lib/maplimit/package.json deleted file mode 100644 index 62b3f99..0000000 --- a/lib/maplimit/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.maplimit", - "description": "async maplimitmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.doparallellimit": "0.5.2", - "async.util.mapasync": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "maplimit" - ] -} diff --git a/lib/mapseries/.editorconfig b/lib/mapseries/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/mapseries/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/mapseries/.gitignore b/lib/mapseries/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/mapseries/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/mapseries/.jscsrc b/lib/mapseries/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/mapseries/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/mapseries/.jshintrc b/lib/mapseries/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/mapseries/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/mapseries/README.md b/lib/mapseries/README.md deleted file mode 100644 index 4188274..0000000 --- a/lib/mapseries/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.mapseries - - -[](https://david-dm.org/async-js/async.mapseries) -[](https://david-dm.org/async-js/async.mapseries#info=devDependencies) -[](https://www.npmjs.org/package/async.mapseries) -[](https://paypal.me/kikobeats) - -> [async#mapseries](https://github.com/async-js/async#async.mapseries) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/mapseries/index.js b/lib/mapseries/index.js deleted file mode 100644 index a354302..0000000 --- a/lib/mapseries/index.js +++ /dev/null @@ -1,4 +0,0 @@ -'use strict'; -var mapAsync = require('async.util.mapasync'); -var doSeries = require('async.util.doseries'); -module.exports = doSeries(mapAsync); diff --git a/lib/mapseries/package.json b/lib/mapseries/package.json deleted file mode 100644 index f292887..0000000 --- a/lib/mapseries/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.mapseries", - "description": "async mapseriesmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.doseries": "0.5.2", - "async.util.mapasync": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "mapseries" - ] -} diff --git a/lib/memoize/index.js b/lib/memoize.js index 2a6f743..7a87af0 100644 --- a/lib/memoize/index.js +++ b/lib/memoize.js @@ -1,10 +1,11 @@ 'use strict'; -var identity = require('async.util.identity'); -var restParam = require('async.util.restparam'); -var setImmediate = require('async.util.setimmediate'); +import identity from 'lodash/utility/identity'; +import restParam from 'lodash/function/restParam'; -module.exports = function memoize(fn, hasher) { +import setImmediate from './internal/setImmediate'; + +export default function memoize(fn, hasher) { var memo = {}; var queues = {}; hasher = hasher || identity; @@ -32,4 +33,4 @@ module.exports = function memoize(fn, hasher) { memoized.memo = memo; memoized.unmemoized = fn; return memoized; -}; +} diff --git a/lib/memoize/.editorconfig b/lib/memoize/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/memoize/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/memoize/.gitignore b/lib/memoize/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/memoize/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/memoize/.jscsrc b/lib/memoize/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/memoize/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/memoize/.jshintrc b/lib/memoize/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/memoize/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/memoize/README.md b/lib/memoize/README.md deleted file mode 100644 index 02d3be3..0000000 --- a/lib/memoize/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.memoize - - -[](https://david-dm.org/async-js/async.memoize) -[](https://david-dm.org/async-js/async.memoize#info=devDependencies) -[](https://www.npmjs.org/package/async.memoize) -[](https://paypal.me/kikobeats) - -> [async#memoize](https://github.com/async-js/async#async.memoize) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/memoize/package.json b/lib/memoize/package.json deleted file mode 100644 index 6802684..0000000 --- a/lib/memoize/package.json +++ /dev/null @@ -1,22 +0,0 @@ -{ - "name": "async.memoize", - "description": "async memoizemethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.identity": "0.5.2", - "async.util.restparam": "0.5.2", - "async.util.setimmediate": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "memoize" - ] -} diff --git a/lib/nextTick.js b/lib/nextTick.js new file mode 100644 index 0000000..b61a8b4 --- /dev/null +++ b/lib/nextTick.js @@ -0,0 +1,7 @@ +'use strict'; + +import setImmediate from './internal/setImmediate'; + +var nexTick = typeof process === 'object' && typeof process.nextTick === 'function' ? process.nextTick : setImmediate; + +export default nexTick; diff --git a/lib/nexttick/.editorconfig b/lib/nexttick/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/nexttick/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/nexttick/.gitignore b/lib/nexttick/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/nexttick/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/nexttick/.jscsrc b/lib/nexttick/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/nexttick/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/nexttick/.jshintrc b/lib/nexttick/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/nexttick/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/nexttick/README.md b/lib/nexttick/README.md deleted file mode 100644 index cd71056..0000000 --- a/lib/nexttick/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.nexttick - - -[](https://david-dm.org/async-js/async.nexttick) -[](https://david-dm.org/async-js/async.nexttick#info=devDependencies) -[](https://www.npmjs.org/package/async.nexttick) -[](https://paypal.me/kikobeats) - -> [async#nexttick](https://github.com/async-js/async#async.nexttick) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/nexttick/index.js b/lib/nexttick/index.js deleted file mode 100644 index 1c8039a..0000000 --- a/lib/nexttick/index.js +++ /dev/null @@ -1,2 +0,0 @@ -'use strict'; -module.exports = require('async.util.nexttick'); diff --git a/lib/nexttick/package.json b/lib/nexttick/package.json deleted file mode 100644 index 61c3483..0000000 --- a/lib/nexttick/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.nexttick", - "description": "async nexttickmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.nexttick": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "nexttick" - ] -} diff --git a/lib/parallel.js b/lib/parallel.js new file mode 100644 index 0000000..d3eec16 --- /dev/null +++ b/lib/parallel.js @@ -0,0 +1,8 @@ +'use strict'; + +import _parallel from './internal/parallel'; +import eachOf from './eachOf'; + +export default function parallel(tasks, cb) { + return _parallel(eachOf, tasks, cb); +} diff --git a/lib/parallel/.editorconfig b/lib/parallel/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/parallel/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/parallel/.gitignore b/lib/parallel/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/parallel/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/parallel/.jscsrc b/lib/parallel/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/parallel/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/parallel/.jshintrc b/lib/parallel/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/parallel/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/parallel/README.md b/lib/parallel/README.md deleted file mode 100644 index 03995dc..0000000 --- a/lib/parallel/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.parallel - - -[](https://david-dm.org/async-js/async.parallel) -[](https://david-dm.org/async-js/async.parallel#info=devDependencies) -[](https://www.npmjs.org/package/async.parallel) -[](https://paypal.me/kikobeats) - -> [async#parallel](https://github.com/async-js/async#async.parallel) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/parallel/index.js b/lib/parallel/index.js deleted file mode 100644 index 6284baf..0000000 --- a/lib/parallel/index.js +++ /dev/null @@ -1,8 +0,0 @@ -'use strict'; - -var eachOf = require('async.eachof'); -var _parallel = require('async.util.parallel'); - -module.exports = function parallel(tasks, cb) { - return _parallel(eachOf, tasks, cb); -}; diff --git a/lib/parallel/package.json b/lib/parallel/package.json deleted file mode 100644 index f11bb40..0000000 --- a/lib/parallel/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.parallel", - "description": "async parallelmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachof": "0.5.2", - "async.util.parallel": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "parallel" - ] -} diff --git a/lib/parallelLimit.js b/lib/parallelLimit.js new file mode 100644 index 0000000..7e66bed --- /dev/null +++ b/lib/parallelLimit.js @@ -0,0 +1,8 @@ +'use strict'; + +import eachOfLimit from './internal/eachOfLimit'; +import parallel from './internal/parallel'; + +export default function parallelLimit(tasks, limit, cb) { + return parallel(eachOfLimit(limit), tasks, cb); +} diff --git a/lib/parallellimit/.editorconfig b/lib/parallellimit/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/parallellimit/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/parallellimit/.gitignore b/lib/parallellimit/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/parallellimit/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/parallellimit/.jscsrc b/lib/parallellimit/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/parallellimit/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/parallellimit/.jshintrc b/lib/parallellimit/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/parallellimit/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/parallellimit/README.md b/lib/parallellimit/README.md deleted file mode 100644 index b5d9c5c..0000000 --- a/lib/parallellimit/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.parallellimit - - -[](https://david-dm.org/async-js/async.parallellimit) -[](https://david-dm.org/async-js/async.parallellimit#info=devDependencies) -[](https://www.npmjs.org/package/async.parallellimit) -[](https://paypal.me/kikobeats) - -> [async#parallellimit](https://github.com/async-js/async#async.parallellimit) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/parallellimit/index.js b/lib/parallellimit/index.js deleted file mode 100644 index c2c8e8b..0000000 --- a/lib/parallellimit/index.js +++ /dev/null @@ -1,8 +0,0 @@ -'use strict'; - -var parallel = require('async.util.parallel'); -var eachOfLimit = require('async.util.eachoflimit'); - -module.exports = function parallelLimit(tasks, limit, cb) { - return parallel(eachOfLimit(limit), tasks, cb); -}; diff --git a/lib/parallellimit/package.json b/lib/parallellimit/package.json deleted file mode 100644 index afdd020..0000000 --- a/lib/parallellimit/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.parallellimit", - "description": "async parallellimitmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.eachoflimit": "0.5.2", - "async.util.parallel": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "parallellimit" - ] -} diff --git a/lib/priorityqueue/index.js b/lib/priorityQueue.js index 7561f9c..b9c1b53 100644 --- a/lib/priorityqueue/index.js +++ b/lib/priorityQueue.js @@ -1,13 +1,14 @@ 'use strict'; -var queue = require('async.queue'); -var noop = require('async.util.noop'); -var isArray = require('async.util.isarray'); -var arrayEach = require('async.util.arrayeach'); -var setImmediate = require('async.util.setimmediate'); +import arrayEach from 'lodash/internal/arrayEach'; +import isArray from 'lodash/lang/isArray'; +import noop from 'lodash/utility/noop'; -module.exports = function(worker, concurrency) { +import setImmediate from './setImmediate'; +import queue from './queue'; + +export default function(worker, concurrency) { function _compareTasks(a, b) { return a.priority - b.priority; } @@ -27,8 +28,8 @@ module.exports = function(worker, concurrency) { } function _insert(q, data, priority, callback) { - if (callback != null && typeof callback !== "function") { - throw new Error("task callback must be a function"); + if (callback != null && typeof callback !== 'function') { + throw new Error('task callback must be a function'); } q.started = true; if (!isArray(data)) { @@ -68,4 +69,4 @@ module.exports = function(worker, concurrency) { delete q.unshift; return q; -}; +} diff --git a/lib/priorityqueue/.editorconfig b/lib/priorityqueue/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/priorityqueue/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/priorityqueue/.gitignore b/lib/priorityqueue/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/priorityqueue/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/priorityqueue/.jscsrc b/lib/priorityqueue/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/priorityqueue/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/priorityqueue/.jshintrc b/lib/priorityqueue/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/priorityqueue/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/priorityqueue/README.md b/lib/priorityqueue/README.md deleted file mode 100644 index 29a8277..0000000 --- a/lib/priorityqueue/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.priorityqueue - - -[](https://david-dm.org/async-js/async.priorityqueue) -[](https://david-dm.org/async-js/async.priorityqueue#info=devDependencies) -[](https://www.npmjs.org/package/async.priorityqueue) -[](https://paypal.me/kikobeats) - -> [async#priorityqueue](https://github.com/async-js/async#async.priorityqueue) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/priorityqueue/package.json b/lib/priorityqueue/package.json deleted file mode 100644 index 8256da7..0000000 --- a/lib/priorityqueue/package.json +++ /dev/null @@ -1,24 +0,0 @@ -{ - "name": "async.priorityqueue", - "description": "async priorityqueuemethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.queue": "0.5.2", - "async.util.arrayeach": "0.5.2", - "async.util.isarray": "0.5.2", - "async.util.noop": "0.5.2", - "async.util.setimmediate": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "priorityqueue" - ] -} diff --git a/lib/queue/index.js b/lib/queue.js index 9e1b185..de2ac93 100644 --- a/lib/queue/index.js +++ b/lib/queue.js @@ -1,9 +1,9 @@ 'use strict'; -var queue = require('async.util.queue'); +import queue from './internal/queue'; -module.exports = function (worker, concurrency) { +export default function (worker, concurrency) { return queue(function (items, cb) { worker(items[0], cb); }, concurrency, 1); -}; +} diff --git a/lib/queue/.editorconfig b/lib/queue/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/queue/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/queue/.gitignore b/lib/queue/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/queue/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/queue/.jscsrc b/lib/queue/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/queue/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/queue/.jshintrc b/lib/queue/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/queue/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/queue/README.md b/lib/queue/README.md deleted file mode 100644 index 9fab925..0000000 --- a/lib/queue/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.queue - - -[](https://david-dm.org/async-js/async.queue) -[](https://david-dm.org/async-js/async.queue#info=devDependencies) -[](https://www.npmjs.org/package/async.queue) -[](https://paypal.me/kikobeats) - -> [async#queue](https://github.com/async-js/async#async.queue) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/queue/package.json b/lib/queue/package.json deleted file mode 100644 index 93e6f5f..0000000 --- a/lib/queue/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.queue", - "description": "async queuemethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.queue": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "queue" - ] -} diff --git a/lib/reduce/index.js b/lib/reduce.js index 541becb..51b736a 100644 --- a/lib/reduce/index.js +++ b/lib/reduce.js @@ -1,8 +1,8 @@ 'use strict'; -var eachOfSeries = require('async.eachofseries'); +import eachOfSeries from './eachOfSeries'; -module.exports = function reduce(arr, memo, iterator, cb) { +export default function reduce(arr, memo, iterator, cb) { eachOfSeries(arr, function(x, i, cb) { iterator(memo, x, function(err, v) { memo = v; @@ -11,4 +11,4 @@ module.exports = function reduce(arr, memo, iterator, cb) { }, function(err) { cb(err, memo); }); -}; +} diff --git a/lib/reduce/.editorconfig b/lib/reduce/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/reduce/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/reduce/.gitignore b/lib/reduce/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/reduce/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/reduce/.jscsrc b/lib/reduce/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/reduce/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/reduce/.jshintrc b/lib/reduce/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/reduce/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/reduce/README.md b/lib/reduce/README.md deleted file mode 100644 index 692debc..0000000 --- a/lib/reduce/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.reduce - - -[](https://david-dm.org/async-js/async.reduce) -[](https://david-dm.org/async-js/async.reduce#info=devDependencies) -[](https://www.npmjs.org/package/async.reduce) -[](https://paypal.me/kikobeats) - -> [async#reduce](https://github.com/async-js/async#async.reduce) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/reduce/package.json b/lib/reduce/package.json deleted file mode 100644 index a673557..0000000 --- a/lib/reduce/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.reduce", - "description": "async reducemethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachofseries": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "reduce" - ] -} diff --git a/lib/reduceRight.js b/lib/reduceRight.js new file mode 100644 index 0000000..f465dbe --- /dev/null +++ b/lib/reduceRight.js @@ -0,0 +1,9 @@ +'use strict'; + +import toArray from 'lodash/lang/toArray'; +import reduce from './reduce'; + +export default function reduceRight (arr, memo, iterator, cb) { + var reversed = toArray(arr).reverse(); + reduce(reversed, memo, iterator, cb); +} diff --git a/lib/reduceright/.editorconfig b/lib/reduceright/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/reduceright/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/reduceright/.gitignore b/lib/reduceright/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/reduceright/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/reduceright/.jscsrc b/lib/reduceright/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/reduceright/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/reduceright/.jshintrc b/lib/reduceright/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/reduceright/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/reduceright/README.md b/lib/reduceright/README.md deleted file mode 100644 index 95268b9..0000000 --- a/lib/reduceright/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.reduceright - - -[](https://david-dm.org/async-js/async.reduceright) -[](https://david-dm.org/async-js/async.reduceright#info=devDependencies) -[](https://www.npmjs.org/package/async.reduceright) -[](https://paypal.me/kikobeats) - -> [async#reduceright](https://github.com/async-js/async#async.reduceright) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/reduceright/index.js b/lib/reduceright/index.js deleted file mode 100644 index 2e86c1e..0000000 --- a/lib/reduceright/index.js +++ /dev/null @@ -1,10 +0,0 @@ -'use strict'; - -var map = require('async.util.map'); -var reduce = require('async.reduce'); -var identity = require('async.util.identity'); - -module.exports = function reduceRight (arr, memo, iterator, cb) { - var reversed = map(arr, identity).reverse(); - reduce(reversed, memo, iterator, cb); -}; diff --git a/lib/reduceright/package.json b/lib/reduceright/package.json deleted file mode 100644 index ba61340..0000000 --- a/lib/reduceright/package.json +++ /dev/null @@ -1,22 +0,0 @@ -{ - "name": "async.reduceright", - "description": "async reducerightmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.reduce": "0.5.2", - "async.util.identity": "0.5.2", - "async.util.map": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "reduceright" - ] -} diff --git a/lib/reject.js b/lib/reject.js new file mode 100644 index 0000000..fb5b87f --- /dev/null +++ b/lib/reject.js @@ -0,0 +1,6 @@ +'use strict'; + +import reject from './internal/reject'; +import doParallel from './internal/doParallel'; + +export default doParallel(reject); diff --git a/lib/reject/.editorconfig b/lib/reject/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/reject/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/reject/.gitignore b/lib/reject/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/reject/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/reject/.jscsrc b/lib/reject/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/reject/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/reject/.jshintrc b/lib/reject/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/reject/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/reject/README.md b/lib/reject/README.md deleted file mode 100644 index 5343532..0000000 --- a/lib/reject/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.reject - - -[](https://david-dm.org/async-js/async.reject) -[](https://david-dm.org/async-js/async.reject#info=devDependencies) -[](https://www.npmjs.org/package/async.reject) -[](https://paypal.me/kikobeats) - -> [async#reject](https://github.com/async-js/async#async.reject) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/reject/index.js b/lib/reject/index.js deleted file mode 100644 index b183176..0000000 --- a/lib/reject/index.js +++ /dev/null @@ -1,6 +0,0 @@ -'use strict'; - -var reject = require('async.util.reject'); -var doParallel = require('async.util.doparallel'); - -module.exports = doParallel(reject); diff --git a/lib/reject/package.json b/lib/reject/package.json deleted file mode 100644 index 01e119b..0000000 --- a/lib/reject/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.reject", - "description": "async rejectmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.doparallel": "0.5.2", - "async.util.reject": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "reject" - ] -} diff --git a/lib/rejectLimit.js b/lib/rejectLimit.js new file mode 100644 index 0000000..7cefed6 --- /dev/null +++ b/lib/rejectLimit.js @@ -0,0 +1,6 @@ +'use strict'; + +import reject from './internal/reject'; +import doParallelLimit from './internal/doParallelLimit'; + +export default doParallelLimit(reject); diff --git a/lib/rejectSeries.js b/lib/rejectSeries.js new file mode 100644 index 0000000..e02adea --- /dev/null +++ b/lib/rejectSeries.js @@ -0,0 +1,6 @@ +'use strict'; + +import reject from './internal/reject'; +import doSeries from './internal/doSeries'; + +export default doSeries(reject); diff --git a/lib/rejectlimit/.editorconfig b/lib/rejectlimit/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/rejectlimit/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/rejectlimit/.gitignore b/lib/rejectlimit/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/rejectlimit/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/rejectlimit/.jscsrc b/lib/rejectlimit/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/rejectlimit/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/rejectlimit/.jshintrc b/lib/rejectlimit/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/rejectlimit/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/rejectlimit/README.md b/lib/rejectlimit/README.md deleted file mode 100644 index 7306b18..0000000 --- a/lib/rejectlimit/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.rejectlimit - - -[](https://david-dm.org/async-js/async.rejectlimit) -[](https://david-dm.org/async-js/async.rejectlimit#info=devDependencies) -[](https://www.npmjs.org/package/async.rejectlimit) -[](https://paypal.me/kikobeats) - -> [async#rejectlimit](https://github.com/async-js/async#async.rejectlimit) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/rejectlimit/index.js b/lib/rejectlimit/index.js deleted file mode 100644 index a758388..0000000 --- a/lib/rejectlimit/index.js +++ /dev/null @@ -1,6 +0,0 @@ -'use strict'; - -var reject = require('async.util.reject'); -var doParallelLimit = require('async.util.doparallellimit'); - -module.exports = doParallelLimit(reject); diff --git a/lib/rejectlimit/package.json b/lib/rejectlimit/package.json deleted file mode 100644 index ae0aec5..0000000 --- a/lib/rejectlimit/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.rejectlimit", - "description": "async rejectlimitmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.doparallellimit": "0.5.2", - "async.util.reject": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "rejectlimit" - ] -} diff --git a/lib/rejectseries/.editorconfig b/lib/rejectseries/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/rejectseries/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/rejectseries/.gitignore b/lib/rejectseries/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/rejectseries/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/rejectseries/.jscsrc b/lib/rejectseries/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/rejectseries/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/rejectseries/.jshintrc b/lib/rejectseries/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/rejectseries/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/rejectseries/README.md b/lib/rejectseries/README.md deleted file mode 100644 index 4d84ce5..0000000 --- a/lib/rejectseries/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.rejectseries - - -[](https://david-dm.org/async-js/async.rejectseries) -[](https://david-dm.org/async-js/async.rejectseries#info=devDependencies) -[](https://www.npmjs.org/package/async.rejectseries) -[](https://paypal.me/kikobeats) - -> [async#rejectseries](https://github.com/async-js/async#async.rejectseries) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/rejectseries/index.js b/lib/rejectseries/index.js deleted file mode 100644 index 4d90ce5..0000000 --- a/lib/rejectseries/index.js +++ /dev/null @@ -1,6 +0,0 @@ -'use strict'; - -var reject = require('async.util.reject'); -var doSeries = require('async.util.doseries'); - -module.exports = doSeries(reject); diff --git a/lib/rejectseries/package.json b/lib/rejectseries/package.json deleted file mode 100644 index 6be6413..0000000 --- a/lib/rejectseries/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.rejectseries", - "description": "async rejectseriesmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.doseries": "0.5.2", - "async.util.reject": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "rejectseries" - ] -} diff --git a/lib/retry/index.js b/lib/retry.js index 00f0c07..9ed4c0e 100644 --- a/lib/retry/index.js +++ b/lib/retry.js @@ -1,8 +1,8 @@ 'use strict'; -var series = require('async.series'); +import series from './series'; -module.exports = function retry(times, task, cb) { +export default function retry(times, task, cb) { var DEFAULT_TIMES = 5; var DEFAULT_INTERVAL = 0; diff --git a/lib/retry/.editorconfig b/lib/retry/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/retry/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/retry/.gitignore b/lib/retry/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/retry/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/retry/.jscsrc b/lib/retry/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/retry/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/retry/.jshintrc b/lib/retry/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/retry/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/retry/README.md b/lib/retry/README.md deleted file mode 100644 index 6e8afbc..0000000 --- a/lib/retry/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.retry - - -[](https://david-dm.org/async-js/async.retry) -[](https://david-dm.org/async-js/async.retry#info=devDependencies) -[](https://www.npmjs.org/package/async.retry) -[](https://paypal.me/kikobeats) - -> [async#retry](https://github.com/async-js/async#async.retry) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/retry/package.json b/lib/retry/package.json deleted file mode 100644 index d03cf75..0000000 --- a/lib/retry/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.retry", - "description": "async retrymethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.series": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "retry" - ] -} diff --git a/lib/seq/index.js b/lib/seq.js index 9246fe5..184dc4b 100644 --- a/lib/seq/index.js +++ b/lib/seq.js @@ -1,8 +1,8 @@ -var noop = require('async.util.noop'); -var reduce = require('async.reduce'); -var restParam = require('async.util.restparam'); +import noop from 'lodash/utility/noop'; +import reduce from './reduce'; +import restParam from 'lodash/function/restParam'; -module.exports = function seq( /* functions... */ ) { +export default function seq( /* functions... */ ) { var fns = arguments; return restParam(function(args) { var that = this; @@ -23,4 +23,4 @@ module.exports = function seq( /* functions... */ ) { cb.apply(that, [err].concat(results)); }); }); -}; +} diff --git a/lib/seq/.editorconfig b/lib/seq/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/seq/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/seq/.gitignore b/lib/seq/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/seq/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/seq/.jscsrc b/lib/seq/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/seq/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/seq/.jshintrc b/lib/seq/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/seq/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/seq/README.md b/lib/seq/README.md deleted file mode 100644 index fd2c880..0000000 --- a/lib/seq/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.seq - - -[](https://david-dm.org/async-js/async.seq) -[](https://david-dm.org/async-js/async.seq#info=devDependencies) -[](https://www.npmjs.org/package/async.seq) -[](https://paypal.me/kikobeats) - -> [async#seq](https://github.com/async-js/async#async.seq) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/seq/package.json b/lib/seq/package.json deleted file mode 100644 index 13daa3c..0000000 --- a/lib/seq/package.json +++ /dev/null @@ -1,22 +0,0 @@ -{ - "name": "async.seq", - "description": "async seqmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.reduce": "0.5.2", - "async.util.noop": "0.5.2", - "async.util.restparam": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "seq" - ] -} diff --git a/lib/series.js b/lib/series.js new file mode 100644 index 0000000..bd8e15d --- /dev/null +++ b/lib/series.js @@ -0,0 +1,8 @@ +'use strict'; + +import parallel from './internal/parallel'; +import eachOfSeries from './eachOfSeries'; + +export default function series(tasks, cb) { + return parallel(eachOfSeries, tasks, cb); +} diff --git a/lib/series/.editorconfig b/lib/series/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/series/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/series/.gitignore b/lib/series/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/series/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/series/.jscsrc b/lib/series/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/series/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/series/.jshintrc b/lib/series/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/series/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/series/README.md b/lib/series/README.md deleted file mode 100644 index 36a95e1..0000000 --- a/lib/series/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.series - - -[](https://david-dm.org/async-js/async.series) -[](https://david-dm.org/async-js/async.series#info=devDependencies) -[](https://www.npmjs.org/package/async.series) -[](https://paypal.me/kikobeats) - -> [async#series](https://github.com/async-js/async#async.series) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/series/index.js b/lib/series/index.js deleted file mode 100644 index 01828f2..0000000 --- a/lib/series/index.js +++ /dev/null @@ -1,8 +0,0 @@ -'use strict'; - -var parallel = require('async.util.parallel'); -var eachOfSeries = require('async.eachofseries'); - -module.exports = function series(tasks, cb) { - return parallel(eachOfSeries, tasks, cb); -}; diff --git a/lib/series/package.json b/lib/series/package.json deleted file mode 100644 index 77bbe4f..0000000 --- a/lib/series/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.series", - "description": "async seriesmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachofseries": "0.5.2", - "async.util.parallel": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "series" - ] -} diff --git a/lib/setImmediate.js b/lib/setImmediate.js new file mode 100644 index 0000000..05d9555 --- /dev/null +++ b/lib/setImmediate.js @@ -0,0 +1,5 @@ +'use strict'; + +import setImmediate from './internal/setImmediate'; + +export default setImmediate; diff --git a/lib/setimmediate/.editorconfig b/lib/setimmediate/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/setimmediate/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/setimmediate/.gitignore b/lib/setimmediate/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/setimmediate/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/setimmediate/.jscsrc b/lib/setimmediate/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/setimmediate/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/setimmediate/.jshintrc b/lib/setimmediate/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/setimmediate/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/setimmediate/README.md b/lib/setimmediate/README.md deleted file mode 100644 index 58fef01..0000000 --- a/lib/setimmediate/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.setimmediate - - -[](https://david-dm.org/async-js/async.setimmediate) -[](https://david-dm.org/async-js/async.setimmediate#info=devDependencies) -[](https://www.npmjs.org/package/async.setimmediate) -[](https://paypal.me/kikobeats) - -> [async#setimmediate](https://github.com/async-js/async#async.setimmediate) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/setimmediate/index.js b/lib/setimmediate/index.js deleted file mode 100644 index 3437d46..0000000 --- a/lib/setimmediate/index.js +++ /dev/null @@ -1,2 +0,0 @@ -'use strict'; -module.exports = require('async.util.setimmediate'); diff --git a/lib/setimmediate/package.json b/lib/setimmediate/package.json deleted file mode 100644 index 6a66eff..0000000 --- a/lib/setimmediate/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.setimmediate", - "description": "async setimmediatemethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.setimmediate": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "setimmediate" - ] -} diff --git a/lib/some.js b/lib/some.js new file mode 100644 index 0000000..6a0e178 --- /dev/null +++ b/lib/some.js @@ -0,0 +1,8 @@ +'use strict'; + +import identity from 'lodash/utility/identity'; + +import createTester from './internal/createTester'; +import eachOf from './eachOf'; + +export default createTester(eachOf, Boolean, identity); diff --git a/lib/some/.editorconfig b/lib/some/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/some/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/some/.gitignore b/lib/some/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/some/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/some/.jscsrc b/lib/some/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/some/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/some/.jshintrc b/lib/some/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/some/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/some/README.md b/lib/some/README.md deleted file mode 100644 index 75ca4f2..0000000 --- a/lib/some/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.some - - -[](https://david-dm.org/async-js/async.some) -[](https://david-dm.org/async-js/async.some#info=devDependencies) -[](https://www.npmjs.org/package/async.some) -[](https://paypal.me/kikobeats) - -> [async#some](https://github.com/async-js/async#async.some) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/some/index.js b/lib/some/index.js deleted file mode 100644 index a8f206c..0000000 --- a/lib/some/index.js +++ /dev/null @@ -1,8 +0,0 @@ -'use strict'; - -var eachOf = require('async.eachof'); -var toBool = require('async.util.tobool'); -var identity = require('async.util.identity'); -var createTester = require('async.util.createtester'); - -module.exports = createTester(eachOf, toBool, identity); diff --git a/lib/some/package.json b/lib/some/package.json deleted file mode 100644 index cb511f0..0000000 --- a/lib/some/package.json +++ /dev/null @@ -1,23 +0,0 @@ -{ - "name": "async.some", - "description": "async somemethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachof": "0.5.2", - "async.util.createtester": "0.5.2", - "async.util.identity": "0.5.2", - "async.util.tobool": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "some" - ] -} diff --git a/lib/someLimit.js b/lib/someLimit.js new file mode 100644 index 0000000..ac239cd --- /dev/null +++ b/lib/someLimit.js @@ -0,0 +1,7 @@ +'use strict'; + +import createTester from './internal/createTester'; +import eachOfLimit from './eachOfLimit'; +import identity from 'lodash/utility/identity'; + +export default createTester(eachOfLimit, Boolean, identity); diff --git a/lib/somelimit/.editorconfig b/lib/somelimit/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/somelimit/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/somelimit/.gitignore b/lib/somelimit/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/somelimit/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/somelimit/.jscsrc b/lib/somelimit/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/somelimit/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/somelimit/.jshintrc b/lib/somelimit/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/somelimit/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/somelimit/README.md b/lib/somelimit/README.md deleted file mode 100644 index 03e548c..0000000 --- a/lib/somelimit/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.somelimit - - -[](https://david-dm.org/async-js/async.somelimit) -[](https://david-dm.org/async-js/async.somelimit#info=devDependencies) -[](https://www.npmjs.org/package/async.somelimit) -[](https://paypal.me/kikobeats) - -> [async#somelimit](https://github.com/async-js/async#async.somelimit) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/somelimit/index.js b/lib/somelimit/index.js deleted file mode 100644 index ba7561d..0000000 --- a/lib/somelimit/index.js +++ /dev/null @@ -1,8 +0,0 @@ -'use strict'; - -var eachOfLimit = require('async.eachoflimit'); -var toBool = require('async.util.tobool'); -var identity = require('async.util.identity'); -var createTester = require('async.util.createtester'); - -module.exports = createTester(eachOfLimit, toBool, identity); diff --git a/lib/somelimit/package.json b/lib/somelimit/package.json deleted file mode 100644 index bbedb32..0000000 --- a/lib/somelimit/package.json +++ /dev/null @@ -1,23 +0,0 @@ -{ - "name": "async.somelimit", - "description": "async somelimitmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachoflimit": "0.5.2", - "async.util.createtester": "0.5.2", - "async.util.identity": "0.5.2", - "async.util.tobool": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "somelimit" - ] -} diff --git a/lib/sortby/index.js b/lib/sortBy.js index 3bf5953..033a6c8 100644 --- a/lib/sortby/index.js +++ b/lib/sortBy.js @@ -1,23 +1,23 @@ 'use strict'; -var map = require('async.util.map'); -var mapAsync = require('async.map'); +import arrayMap from 'lodash/internal/arrayMap'; +import property from 'lodash/utility/property'; -module.exports = function sortBy (arr, iterator, cb) { - mapAsync(arr, function (x, cb) { +import map from './map'; + +export default function sortBy (arr, iterator, cb) { + map(arr, function (x, cb) { iterator(x, function (err, criteria) { if (err) return cb(err); cb(null, {value: x, criteria: criteria}); }); }, function (err, results) { if (err) return cb(err); - cb(null, map(results.sort(comparator), function (x) { - return x.value; - })); + cb(null, arrayMap(results.sort(comparator), property('value'))); }); function comparator(left, right) { var a = left.criteria, b = right.criteria; return a < b ? -1 : a > b ? 1 : 0; } -}; +} diff --git a/lib/sortby/.editorconfig b/lib/sortby/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/sortby/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/sortby/.gitignore b/lib/sortby/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/sortby/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/sortby/.jscsrc b/lib/sortby/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/sortby/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/sortby/.jshintrc b/lib/sortby/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/sortby/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/sortby/README.md b/lib/sortby/README.md deleted file mode 100644 index 1b00189..0000000 --- a/lib/sortby/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.sortby - - -[](https://david-dm.org/async-js/async.sortby) -[](https://david-dm.org/async-js/async.sortby#info=devDependencies) -[](https://www.npmjs.org/package/async.sortby) -[](https://paypal.me/kikobeats) - -> [async#sortby](https://github.com/async-js/async#async.sortby) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/sortby/package.json b/lib/sortby/package.json deleted file mode 100644 index 00494ac..0000000 --- a/lib/sortby/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.sortby", - "description": "async sortbymethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.map": "0.5.2", - "async.util.map": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "sortby" - ] -} diff --git a/lib/times.js b/lib/times.js new file mode 100644 index 0000000..48430d4 --- /dev/null +++ b/lib/times.js @@ -0,0 +1,8 @@ +'use strict'; + +import map from './map'; +import range from 'lodash/utility/range'; + +export default function (count, iterator, callback) { + map(range(0, count), iterator, callback); +} diff --git a/lib/times/.editorconfig b/lib/times/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/times/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/times/.gitignore b/lib/times/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/times/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/times/.jscsrc b/lib/times/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/times/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/times/.jshintrc b/lib/times/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/times/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/times/README.md b/lib/times/README.md deleted file mode 100644 index f0e13a8..0000000 --- a/lib/times/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.times - - -[](https://david-dm.org/async-js/async.times) -[](https://david-dm.org/async-js/async.times#info=devDependencies) -[](https://www.npmjs.org/package/async.times) -[](https://paypal.me/kikobeats) - -> [async#times](https://github.com/async-js/async#async.times) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/times/index.js b/lib/times/index.js deleted file mode 100644 index 94cae6f..0000000 --- a/lib/times/index.js +++ /dev/null @@ -1,6 +0,0 @@ -'use strict'; - -var map = require('async.map'); -var times = require('async.util.times'); - -module.exports = times(map); diff --git a/lib/times/package.json b/lib/times/package.json deleted file mode 100644 index a00c4d1..0000000 --- a/lib/times/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.times", - "description": "async timesmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.map": "0.5.2", - "async.util.times": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "times" - ] -} diff --git a/lib/timesLimit.js b/lib/timesLimit.js new file mode 100644 index 0000000..fa36020 --- /dev/null +++ b/lib/timesLimit.js @@ -0,0 +1,8 @@ +'use strict'; + +import mapLimit from './mapLimit'; +import range from 'lodash/utility/range'; + +export default function timeLimit(count, limit, iterator, cb) { + return mapLimit(range(0, count), limit, iterator, cb); +}; diff --git a/lib/timesSeries.js b/lib/timesSeries.js new file mode 100644 index 0000000..410d942 --- /dev/null +++ b/lib/timesSeries.js @@ -0,0 +1,8 @@ +'use strict'; + +import mapSeries from './mapSeries'; +import range from 'lodash/utility/range'; + +export default function (count, iterator, callback) { + mapSeries(range(0, count), iterator, callback); +} diff --git a/lib/timeslimit/.editorconfig b/lib/timeslimit/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/timeslimit/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/timeslimit/.gitignore b/lib/timeslimit/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/timeslimit/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/timeslimit/.jscsrc b/lib/timeslimit/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/timeslimit/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/timeslimit/.jshintrc b/lib/timeslimit/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/timeslimit/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/timeslimit/README.md b/lib/timeslimit/README.md deleted file mode 100644 index 349f7a0..0000000 --- a/lib/timeslimit/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.timeslimit - - -[](https://david-dm.org/async-js/async.timeslimit) -[](https://david-dm.org/async-js/async.timeslimit#info=devDependencies) -[](https://www.npmjs.org/package/async.timeslimit) -[](https://paypal.me/kikobeats) - -> [async#timeslimit](https://github.com/async-js/async#async.timeslimit) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/timeslimit/index.js b/lib/timeslimit/index.js deleted file mode 100644 index 0247d94..0000000 --- a/lib/timeslimit/index.js +++ /dev/null @@ -1,8 +0,0 @@ -'use strict'; - -var range = require('async.util.range'); -var mapLimit = require('async.maplimit'); - -module.exports = function timeLimit(count, limit, iterator, cb) { - return mapLimit(range(count), limit, iterator, cb); -}; diff --git a/lib/timeslimit/package.json b/lib/timeslimit/package.json deleted file mode 100644 index 6aaa4fc..0000000 --- a/lib/timeslimit/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.timeslimit", - "description": "async timeslimitmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.maplimit": "0.5.2", - "async.util.range": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "timeslimit" - ] -} diff --git a/lib/timesseries/.editorconfig b/lib/timesseries/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/timesseries/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/timesseries/.gitignore b/lib/timesseries/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/timesseries/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/timesseries/.jscsrc b/lib/timesseries/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/timesseries/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/timesseries/.jshintrc b/lib/timesseries/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/timesseries/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/timesseries/README.md b/lib/timesseries/README.md deleted file mode 100644 index b83b062..0000000 --- a/lib/timesseries/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.timesseries - - -[](https://david-dm.org/async-js/async.timesseries) -[](https://david-dm.org/async-js/async.timesseries#info=devDependencies) -[](https://www.npmjs.org/package/async.timesseries) -[](https://paypal.me/kikobeats) - -> [async#timesseries](https://github.com/async-js/async#async.timesseries) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/timesseries/index.js b/lib/timesseries/index.js deleted file mode 100644 index e918a6c..0000000 --- a/lib/timesseries/index.js +++ /dev/null @@ -1,6 +0,0 @@ -'use strict'; - -var times = require('async.util.times'); -var mapSeries = require('async.mapseries'); - -module.exports = times(mapSeries); diff --git a/lib/timesseries/package.json b/lib/timesseries/package.json deleted file mode 100644 index 57e4e07..0000000 --- a/lib/timesseries/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.timesseries", - "description": "async timesseriesmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.mapseries": "0.5.2", - "async.util.times": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "timesseries" - ] -} diff --git a/lib/transform/index.js b/lib/transform.js index 8511c56..08d4f3d 100644 --- a/lib/transform/index.js +++ b/lib/transform.js @@ -1,9 +1,10 @@ 'use strict'; -var eachOf = require('async.eachof'); -var isArray = require('async.util.isarray'); +import isArray from 'lodash/lang/isArray'; -module.exports = function transform (arr, memo, iterator, callback) { +import eachOf from './eachOf'; + +export default function transform (arr, memo, iterator, callback) { if (arguments.length === 3) { callback = iterator; iterator = memo; @@ -15,4 +16,4 @@ module.exports = function transform (arr, memo, iterator, callback) { }, function(err) { callback(err, memo); }); -}; +} diff --git a/lib/transform/.editorconfig b/lib/transform/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/transform/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/transform/.gitignore b/lib/transform/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/transform/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/transform/.jscsrc b/lib/transform/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/transform/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/transform/.jshintrc b/lib/transform/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/transform/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/transform/README.md b/lib/transform/README.md deleted file mode 100644 index f37a132..0000000 --- a/lib/transform/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.transform - - -[](https://david-dm.org/async-js/async.transform) -[](https://david-dm.org/async-js/async.transform#info=devDependencies) -[](https://www.npmjs.org/package/async.transform) -[](https://paypal.me/kikobeats) - -> [async#transform](https://github.com/async-js/async#async.transform) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/transform/package.json b/lib/transform/package.json deleted file mode 100644 index 6044bfc..0000000 --- a/lib/transform/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.transform", - "description": "async transformmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.eachof": "0.5.2", - "async.util.isarray": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "transform" - ] -} diff --git a/lib/unmemoize/index.js b/lib/unmemoize.js index a69cc57..9d4aa56 100644 --- a/lib/unmemoize/index.js +++ b/lib/unmemoize.js @@ -1,6 +1,6 @@ 'use strict'; -module.exports = function unmemoize(fn) { +export default function unmemoize(fn) { return function () { return (fn.unmemoized || fn).apply(null, arguments); }; diff --git a/lib/unmemoize/.editorconfig b/lib/unmemoize/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/unmemoize/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/unmemoize/.gitignore b/lib/unmemoize/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/unmemoize/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/unmemoize/.jscsrc b/lib/unmemoize/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/unmemoize/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/unmemoize/.jshintrc b/lib/unmemoize/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/unmemoize/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/unmemoize/README.md b/lib/unmemoize/README.md deleted file mode 100644 index 70d8527..0000000 --- a/lib/unmemoize/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.unmemoize - - -[](https://david-dm.org/async-js/async.unmemoize) -[](https://david-dm.org/async-js/async.unmemoize#info=devDependencies) -[](https://www.npmjs.org/package/async.unmemoize) -[](https://paypal.me/kikobeats) - -> [async#unmemoize](https://github.com/async-js/async#async.unmemoize) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/unmemoize/package.json b/lib/unmemoize/package.json deleted file mode 100644 index 8804342..0000000 --- a/lib/unmemoize/package.json +++ /dev/null @@ -1,17 +0,0 @@ -{ - "name": "async.unmemoize", - "description": "async unmemoizemethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "keywords": [ - "async", - "async-modularized", - "unmemoize" - ] -} diff --git a/lib/until/index.js b/lib/until.js index 704c38b..f9ed2fd 100644 --- a/lib/until/index.js +++ b/lib/until.js @@ -1,9 +1,9 @@ 'use strict'; -var whilst = require('async.whilst'); +import whilst from './whilst'; -module.exports = function until(test, iterator, cb) { +export default function until(test, iterator, cb) { return whilst(function() { return !test.apply(this, arguments); }, iterator, cb); -}; +} diff --git a/lib/until/.editorconfig b/lib/until/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/until/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/until/.gitignore b/lib/until/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/until/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/until/.jscsrc b/lib/until/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/until/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/until/.jshintrc b/lib/until/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/until/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/until/README.md b/lib/until/README.md deleted file mode 100644 index c83cde2..0000000 --- a/lib/until/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.until - - -[](https://david-dm.org/async-js/async.until) -[](https://david-dm.org/async-js/async.until#info=devDependencies) -[](https://www.npmjs.org/package/async.until) -[](https://paypal.me/kikobeats) - -> [async#until](https://github.com/async-js/async#async.until) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/until/package.json b/lib/until/package.json deleted file mode 100644 index bbd3af7..0000000 --- a/lib/until/package.json +++ /dev/null @@ -1,20 +0,0 @@ -{ - "name": "async.until", - "description": "async untilmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.whilst": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "until" - ] -} diff --git a/lib/waterfall/index.js b/lib/waterfall.js index eaf6d78..54f111c 100644 --- a/lib/waterfall/index.js +++ b/lib/waterfall.js @@ -7,7 +7,7 @@ var restParam = require('async.util.restparam'); var ensureAsync = require('async.util.ensureasync'); var iterator = require('async.iterator'); -module.exports = function(tasks, cb) { +export default function(tasks, cb) { cb = once(cb || noop); if (!isArray(tasks)) return cb(new Error('First argument to waterfall must be an array of functions')); if (!tasks.length) return cb(); diff --git a/lib/waterfall/.editorconfig b/lib/waterfall/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/waterfall/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/waterfall/.gitignore b/lib/waterfall/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/waterfall/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/waterfall/.jscsrc b/lib/waterfall/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/waterfall/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/waterfall/.jshintrc b/lib/waterfall/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/waterfall/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/waterfall/README.md b/lib/waterfall/README.md deleted file mode 100644 index 17f5481..0000000 --- a/lib/waterfall/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.waterfall - - -[](https://david-dm.org/async-js/async.waterfall) -[](https://david-dm.org/async-js/async.waterfall#info=devDependencies) -[](https://www.npmjs.org/package/async.waterfall) -[](https://paypal.me/kikobeats) - -> [async#waterfall](https://github.com/async-js/async#async.waterfall) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/waterfall/package.json b/lib/waterfall/package.json deleted file mode 100644 index 3a985cb..0000000 --- a/lib/waterfall/package.json +++ /dev/null @@ -1,25 +0,0 @@ -{ - "name": "async.waterfall", - "description": "async waterfallmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.iterator": "0.5.2", - "async.util.ensureasync": "0.5.2", - "async.util.isarray": "0.5.2", - "async.util.noop": "0.5.2", - "async.util.once": "0.5.2", - "async.util.restparam": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "waterfall" - ] -} diff --git a/lib/whilst/index.js b/lib/whilst.js index a7930a3..b0825c6 100644 --- a/lib/whilst/index.js +++ b/lib/whilst.js @@ -1,9 +1,9 @@ 'use strict'; -var noop = require('async.util.noop'); -var restParam = require('async.util.restparam'); +import noop from 'lodash/utility/noop'; +import restParam from 'lodash/function/restParam'; -module.exports = function whilst(test, iterator, cb) { +export default function whilst(test, iterator, cb) { cb = cb || noop; if (!test()) return cb(null); var next = restParam(function(err, args) { @@ -12,4 +12,4 @@ module.exports = function whilst(test, iterator, cb) { cb.apply(null, [null].concat(args)); }); iterator(next); -}; +} diff --git a/lib/whilst/.editorconfig b/lib/whilst/.editorconfig deleted file mode 100644 index 7f502d4..0000000 --- a/lib/whilst/.editorconfig +++ /dev/null @@ -1,10 +0,0 @@ -# editorconfig.org -root = true - -[*] -end_of_line = lf -charset = utf-8 -trim_trailing_whitespace = true -insert_final_newline = true -indent_style = space -indent_size = 4 diff --git a/lib/whilst/.gitignore b/lib/whilst/.gitignore deleted file mode 100644 index 8feeb01..0000000 --- a/lib/whilst/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -node_modules -dist -perf/versions -nyc_output -coverage -*.log -.DS_Store -npm-debug.log diff --git a/lib/whilst/.jscsrc b/lib/whilst/.jscsrc deleted file mode 100644 index b8cfa17..0000000 --- a/lib/whilst/.jscsrc +++ /dev/null @@ -1,3 +0,0 @@ -{ - "validateIndentation": 4 -}
\ No newline at end of file diff --git a/lib/whilst/.jshintrc b/lib/whilst/.jshintrc deleted file mode 100644 index 76be34a..0000000 --- a/lib/whilst/.jshintrc +++ /dev/null @@ -1,29 +0,0 @@ -{ - // Enforcing options - "eqeqeq": false, - "forin": true, - "indent": 4, - "noarg": true, - "undef": true, - "unused": true, - "trailing": true, - "evil": true, - "laxcomma": true, - - // Relaxing options - "onevar": false, - "asi": false, - "eqnull": true, - "expr": false, - "loopfunc": true, - "sub": true, - "browser": true, - "node": true, - "globals": { - "self": true, - "define": true, - "describe": true, - "context": true, - "it": true - } -} diff --git a/lib/whilst/README.md b/lib/whilst/README.md deleted file mode 100644 index 6ba0e50..0000000 --- a/lib/whilst/README.md +++ /dev/null @@ -1,13 +0,0 @@ -# async.whilst - - -[](https://david-dm.org/async-js/async.whilst) -[](https://david-dm.org/async-js/async.whilst#info=devDependencies) -[](https://www.npmjs.org/package/async.whilst) -[](https://paypal.me/kikobeats) - -> [async#whilst](https://github.com/async-js/async#async.whilst) method as module. - -## License - -MIT © [async-js](https://github.com/async-js) diff --git a/lib/whilst/package.json b/lib/whilst/package.json deleted file mode 100644 index d8e96da..0000000 --- a/lib/whilst/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "async.whilst", - "description": "async whilstmethod as module.", - "main": "./index.js", - "repository": { - "type": "git", - "url": "https://github.com/caolan/async.git" - }, - "author": "Caolan McMahon", - "version": "0.5.2", - "license": "MIT", - "dependencies": { - "async.util.noop": "0.5.2", - "async.util.restparam": "0.5.2" - }, - "keywords": [ - "async", - "async-modularized", - "whilst" - ] -} |