PATH:
opt
/
bitninja-dispatcher
/
node_modules
/
async
'use strict'; Object.defineProperty(exports, "__esModule", { value: true }); var _map = require('./map.js'); var _map2 = _interopRequireDefault(_map); var _wrapAsync = require('./internal/wrapAsync.js'); var _wrapAsync2 = _interopRequireDefault(_wrapAsync); var _awaitify = require('./internal/awaitify.js'); var _awaitify2 = _interopRequireDefault(_awaitify); function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } /** * Sorts a list by the results of running each `coll` value through an async * `iteratee`. * * @name sortBy * @static * @memberOf module:Collections * @method * @category Collection * @param {Array|Iterable|AsyncIterable|Object} coll - A collection to iterate over. * @param {AsyncFunction} iteratee - An async function to apply to each item in * `coll`. * The iteratee should complete with a value to use as the sort criteria as * its `result`. * Invoked with (item, callback). * @param {Function} callback - A callback which is called after all the * `iteratee` functions have finished, or an error occurs. Results is the items * from the original `coll` sorted by the values returned by the `iteratee` * calls. Invoked with (err, results). * @returns {Promise} a promise, if no callback passed * @example * * // bigfile.txt is a file that is 251100 bytes in size * // mediumfile.txt is a file that is 11000 bytes in size * // smallfile.txt is a file that is 121 bytes in size * * // asynchronous function that returns the file size in bytes * function getFileSizeInBytes(file, callback) { * fs.stat(file, function(err, stat) { * if (err) { * return callback(err); * } * callback(null, stat.size); * }); * } * * // Using callbacks * async.sortBy(['mediumfile.txt','smallfile.txt','bigfile.txt'], getFileSizeInBytes, * function(err, results) { * if (err) { * console.log(err); * } else { * console.log(results); * // results is now the original array of files sorted by * // file size (ascending by default), e.g. * // [ 'smallfile.txt', 'mediumfile.txt', 'bigfile.txt'] * } * } * ); * * // By modifying the callback parameter the * // sorting order can be influenced: * * // ascending order * async.sortBy(['mediumfile.txt','smallfile.txt','bigfile.txt'], function(file, callback) { * getFileSizeInBytes(file, function(getFileSizeErr, fileSize) { * if (getFileSizeErr) return callback(getFileSizeErr); * callback(null, fileSize); * }); * }, function(err, results) { * if (err) { * console.log(err); * } else { * console.log(results); * // results is now the original array of files sorted by * // file size (ascending by default), e.g. * // [ 'smallfile.txt', 'mediumfile.txt', 'bigfile.txt'] * } * } * ); * * // descending order * async.sortBy(['bigfile.txt','mediumfile.txt','smallfile.txt'], function(file, callback) { * getFileSizeInBytes(file, function(getFileSizeErr, fileSize) { * if (getFileSizeErr) { * return callback(getFileSizeErr); * } * callback(null, fileSize * -1); * }); * }, function(err, results) { * if (err) { * console.log(err); * } else { * console.log(results); * // results is now the original array of files sorted by * // file size (ascending by default), e.g. * // [ 'bigfile.txt', 'mediumfile.txt', 'smallfile.txt'] * } * } * ); * * // Error handling * async.sortBy(['mediumfile.txt','smallfile.txt','missingfile.txt'], getFileSizeInBytes, * function(err, results) { * if (err) { * console.log(err); * // [ Error: ENOENT: no such file or directory ] * } else { * console.log(results); * } * } * ); * * // Using Promises * async.sortBy(['mediumfile.txt','smallfile.txt','bigfile.txt'], getFileSizeInBytes) * .then( results => { * console.log(results); * // results is now the original array of files sorted by * // file size (ascending by default), e.g. * // [ 'smallfile.txt', 'mediumfile.txt', 'bigfile.txt'] * }).catch( err => { * console.log(err); * }); * * // Error handling * async.sortBy(['mediumfile.txt','smallfile.txt','missingfile.txt'], getFileSizeInBytes) * .then( results => { * console.log(results); * }).catch( err => { * console.log(err); * // [ Error: ENOENT: no such file or directory ] * }); * * // Using async/await * (async () => { * try { * let results = await async.sortBy(['bigfile.txt','mediumfile.txt','smallfile.txt'], getFileSizeInBytes); * console.log(results); * // results is now the original array of files sorted by * // file size (ascending by default), e.g. * // [ 'smallfile.txt', 'mediumfile.txt', 'bigfile.txt'] * } * catch (err) { * console.log(err); * } * })(); * * // Error handling * async () => { * try { * let results = await async.sortBy(['missingfile.txt','mediumfile.txt','smallfile.txt'], getFileSizeInBytes); * console.log(results); * } * catch (err) { * console.log(err); * // [ Error: ENOENT: no such file or directory ] * } * } * */ function sortBy(coll, iteratee, callback) { var _iteratee = (0, _wrapAsync2.default)(iteratee); return (0, _map2.default)(coll, (x, iterCb) => { _iteratee(x, (err, criteria) => { if (err) return iterCb(err); iterCb(err, { value: x, criteria }); }); }, (err, results) => { if (err) return callback(err); callback(null, results.sort(comparator).map(v => v.value)); }); function comparator(left, right) { var a = left.criteria, b = right.criteria; return a < b ? -1 : a > b ? 1 : 0; } } exports.default = (0, _awaitify2.default)(sortBy, 3); module.exports = exports['default'];
[-] concatLimit.js
[edit]
[-] concatSeries.js
[edit]
[-] everySeries.js
[edit]
[-] whilst.js
[edit]
[-] groupBySeries.js
[edit]
[-] asyncify.js
[edit]
[-] auto.js
[edit]
[-] find.js
[edit]
[-] concat.js
[edit]
[-] mapLimit.js
[edit]
[-] allSeries.js
[edit]
[-] tryEach.js
[edit]
[-] detectLimit.js
[edit]
[-] select.js
[edit]
[-] wrapSync.js
[edit]
[-] reflect.js
[edit]
[-] series.js
[edit]
[-] transform.js
[edit]
[-] autoInject.js
[edit]
[-] forEachLimit.js
[edit]
[-] detectSeries.js
[edit]
[-] unmemoize.js
[edit]
[-] reduce.js
[edit]
[-] memoize.js
[edit]
[+]
..
[-] doWhilst.js
[edit]
[-] everyLimit.js
[edit]
[-] flatMapLimit.js
[edit]
[-] priorityQueue.js
[edit]
[-] selectLimit.js
[edit]
[-] timesLimit.js
[edit]
[-] mapValuesSeries.js
[edit]
[-] queue.js
[edit]
[-] forEach.js
[edit]
[-] reflectAll.js
[edit]
[-] cargo.js
[edit]
[-] parallelLimit.js
[edit]
[-] some.js
[edit]
[-] inject.js
[edit]
[-] mapValues.js
[edit]
[-] all.js
[edit]
[-] anySeries.js
[edit]
[-] seq.js
[edit]
[-] cargoQueue.js
[edit]
[-] package.json
[edit]
[-] findLimit.js
[edit]
[-] forever.js
[edit]
[-] detect.js
[edit]
[-] rejectLimit.js
[edit]
[-] retry.js
[edit]
[-] timeout.js
[edit]
[-] forEachOfSeries.js
[edit]
[-] eachOfLimit.js
[edit]
[-] nextTick.js
[edit]
[-] parallel.js
[edit]
[-] foldl.js
[edit]
[-] waterfall.js
[edit]
[-] rejectSeries.js
[edit]
[-] dir.js
[edit]
[-] reduceRight.js
[edit]
[-] flatMap.js
[edit]
[-] times.js
[edit]
[-] someSeries.js
[edit]
[-] setImmediate.js
[edit]
[-] anyLimit.js
[edit]
[-] filterLimit.js
[edit]
[-] findSeries.js
[edit]
[-] applyEach.js
[edit]
[-] groupBy.js
[edit]
[-] eachOf.js
[edit]
[-] retryable.js
[edit]
[-] flatMapSeries.js
[edit]
[-] during.js
[edit]
[-] apply.js
[edit]
[-] forEachOf.js
[edit]
[-] index.js
[edit]
[-] someLimit.js
[edit]
[-] foldr.js
[edit]
[-] eachSeries.js
[edit]
[-] groupByLimit.js
[edit]
[-] race.js
[edit]
[-] reject.js
[edit]
[-] timesSeries.js
[edit]
[-] sortBy.js
[edit]
[-] doUntil.js
[edit]
[-] constant.js
[edit]
[-] ensureAsync.js
[edit]
[-] any.js
[edit]
[+]
internal
[-] map.js
[edit]
[-] filter.js
[edit]
[-] mapValuesLimit.js
[edit]
[-] every.js
[edit]
[-] compose.js
[edit]
[-] selectSeries.js
[edit]
[-] forEachOfLimit.js
[edit]
[-] filterSeries.js
[edit]
[-] each.js
[edit]
[-] eachLimit.js
[edit]
[-] README.md
[edit]
[-] eachOfSeries.js
[edit]
[-] applyEachSeries.js
[edit]
[-] bower.json
[edit]
[-] mapSeries.js
[edit]
[-] until.js
[edit]
[+]
dist
[-] forEachSeries.js
[edit]
[-] log.js
[edit]
[-] doDuring.js
[edit]
[-] LICENSE
[edit]
[-] CHANGELOG.md
[edit]
[-] allLimit.js
[edit]