aboutsummaryrefslogtreecommitdiff
path: root/node_modules/thenify/index.js
diff options
context:
space:
mode:
authorruki <waruqi@gmail.com>2018-11-08 00:38:48 +0800
committerruki <waruqi@gmail.com>2018-11-07 21:53:09 +0800
commit26105034da4fcce7ac883c899d781f016559310d (patch)
treec459a5dc4e3aa0972d9919033ece511ce76dd129 /node_modules/thenify/index.js
parent2c77f00f1a7ecb6c8192f9c16d3b2001b254a107 (diff)
downloadxmake-docs-26105034da4fcce7ac883c899d781f016559310d.tar.gz
xmake-docs-26105034da4fcce7ac883c899d781f016559310d.zip
switch to vuepress
Diffstat (limited to 'node_modules/thenify/index.js')
-rw-r--r--node_modules/thenify/index.js80
1 files changed, 80 insertions, 0 deletions
diff --git a/node_modules/thenify/index.js b/node_modules/thenify/index.js
new file mode 100644
index 00000000..161d32e6
--- /dev/null
+++ b/node_modules/thenify/index.js
@@ -0,0 +1,80 @@
+
+var Promise = require('any-promise')
+var assert = require('assert')
+
+module.exports = thenify
+
+/**
+ * Turn async functions into promises
+ *
+ * @param {Function} $$__fn__$$
+ * @return {Function}
+ * @api public
+ */
+
+function thenify($$__fn__$$, options) {
+ assert(typeof $$__fn__$$ === 'function')
+ return eval(createWrapper($$__fn__$$.name, options))
+}
+
+/**
+ * Turn async functions into promises and backward compatible with callback
+ *
+ * @param {Function} $$__fn__$$
+ * @return {Function}
+ * @api public
+ */
+
+thenify.withCallback = function ($$__fn__$$, options) {
+ assert(typeof $$__fn__$$ === 'function')
+ options = options || {}
+ options.withCallback = true
+ if (options.multiArgs === undefined) options.multiArgs = true
+ return eval(createWrapper($$__fn__$$.name, options))
+}
+
+function createCallback(resolve, reject, multiArgs) {
+ return function(err, value) {
+ if (err) return reject(err)
+ var length = arguments.length
+
+ if (length <= 2 || !multiArgs) return resolve(value)
+
+ if (Array.isArray(multiArgs)) {
+ var values = {}
+ for (var i = 1; i < length; i++) values[multiArgs[i - 1]] = arguments[i]
+ return resolve(values)
+ }
+
+ var values = new Array(length - 1)
+ for (var i = 1; i < length; ++i) values[i - 1] = arguments[i]
+ resolve(values)
+ }
+}
+
+function createWrapper(name, options) {
+ name = (name || '').replace(/\s|bound(?!$)/g, '')
+ options = options || {}
+ // default to true
+ var multiArgs = options.multiArgs !== undefined ? options.multiArgs : true
+ multiArgs = 'var multiArgs = ' + JSON.stringify(multiArgs) + '\n'
+
+ var withCallback = options.withCallback ?
+ 'var lastType = typeof arguments[len - 1]\n'
+ + 'if (lastType === "function") return $$__fn__$$.apply(self, arguments)\n'
+ : ''
+
+ return '(function ' + name + '() {\n'
+ + 'var self = this\n'
+ + 'var len = arguments.length\n'
+ + multiArgs
+ + withCallback
+ + 'var args = new Array(len + 1)\n'
+ + 'for (var i = 0; i < len; ++i) args[i] = arguments[i]\n'
+ + 'var lastIndex = i\n'
+ + 'return new Promise(function (resolve, reject) {\n'
+ + 'args[lastIndex] = createCallback(resolve, reject, multiArgs)\n'
+ + '$$__fn__$$.apply(self, args)\n'
+ + '})\n'
+ + '})'
+}