93 lines
2.9 KiB
JavaScript
93 lines
2.9 KiB
JavaScript
|
'use strict';
|
||
|
|
|
||
|
|
Object.defineProperty(exports, "__esModule", {
|
||
|
|
value: true
|
||
|
|
});
|
||
|
|
exports.default = asyncify;
|
||
|
|
|
||
|
|
var _isObject = require('lodash/isObject');
|
||
|
|
|
||
|
|
var _isObject2 = _interopRequireDefault(_isObject);
|
||
|
|
|
||
|
|
var _initialParams = require('./internal/initialParams');
|
||
|
|
|
||
|
|
var _initialParams2 = _interopRequireDefault(_initialParams);
|
||
|
|
|
||
|
|
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Take a sync function and make it async, passing its return value to a
|
||
|
|
* callback. This is useful for plugging sync functions into a waterfall,
|
||
|
|
* series, or other async functions. Any arguments passed to the generated
|
||
|
|
* function will be passed to the wrapped function (except for the final
|
||
|
|
* callback argument). Errors thrown will be passed to the callback.
|
||
|
|
*
|
||
|
|
* If the function passed to `asyncify` returns a Promise, that promises's
|
||
|
|
* resolved/rejected state will be used to call the callback, rather than simply
|
||
|
|
* the synchronous return value.
|
||
|
|
*
|
||
|
|
* This also means you can asyncify ES2016 `async` functions.
|
||
|
|
*
|
||
|
|
* @name asyncify
|
||
|
|
* @static
|
||
|
|
* @memberOf module:Utils
|
||
|
|
* @method
|
||
|
|
* @alias wrapSync
|
||
|
|
* @category Util
|
||
|
|
* @param {Function} func - The synchronous function to convert to an
|
||
|
|
* asynchronous function.
|
||
|
|
* @returns {Function} An asynchronous wrapper of the `func`. To be invoked with
|
||
|
|
* (callback).
|
||
|
|
* @example
|
||
|
|
*
|
||
|
|
* // passing a regular synchronous function
|
||
|
|
* async.waterfall([
|
||
|
|
* async.apply(fs.readFile, filename, "utf8"),
|
||
|
|
* async.asyncify(JSON.parse),
|
||
|
|
* function (data, next) {
|
||
|
|
* // data is the result of parsing the text.
|
||
|
|
* // If there was a parsing error, it would have been caught.
|
||
|
|
* }
|
||
|
|
* ], callback);
|
||
|
|
*
|
||
|
|
* // passing a function returning a promise
|
||
|
|
* async.waterfall([
|
||
|
|
* async.apply(fs.readFile, filename, "utf8"),
|
||
|
|
* async.asyncify(function (contents) {
|
||
|
|
* return db.model.create(contents);
|
||
|
|
* }),
|
||
|
|
* function (model, next) {
|
||
|
|
* // `model` is the instantiated model object.
|
||
|
|
* // If there was an error, this function would be skipped.
|
||
|
|
* }
|
||
|
|
* ], callback);
|
||
|
|
*
|
||
|
|
* // es6 example
|
||
|
|
* var q = async.queue(async.asyncify(async function(file) {
|
||
|
|
* var intermediateStep = await processFile(file);
|
||
|
|
* return await somePromise(intermediateStep)
|
||
|
|
* }));
|
||
|
|
*
|
||
|
|
* q.push(files);
|
||
|
|
*/
|
||
|
|
function asyncify(func) {
|
||
|
|
return (0, _initialParams2.default)(function (args, callback) {
|
||
|
|
var result;
|
||
|
|
try {
|
||
|
|
result = func.apply(this, args);
|
||
|
|
} catch (e) {
|
||
|
|
return callback(e);
|
||
|
|
}
|
||
|
|
// if result is Promise object
|
||
|
|
if ((0, _isObject2.default)(result) && typeof result.then === 'function') {
|
||
|
|
result.then(function (value) {
|
||
|
|
callback(null, value);
|
||
|
|
}, function (err) {
|
||
|
|
callback(err.message ? err : new Error(err));
|
||
|
|
});
|
||
|
|
} else {
|
||
|
|
callback(null, result);
|
||
|
|
}
|
||
|
|
});
|
||
|
|
}
|
||
|
|
module.exports = exports['default'];
|