promisify 的过程
栏目: JavaScript · 发布时间: 7年前
内容简介:bluebird 中的promisify的原型源码是可以看到在判断了是否是函数的同时判断了fn是否已经被promise化过。 这里的参数以(fn,undefined)为例,调用的promisify函数传入的参数是(fn,{},false)
bluebird 中的promisify的原型源码是
Promise.promisify = function (fn, options) {
if (typeof fn !== "function") {
throw new TypeError("expecting a function but got " + util.classString(fn));
}
if (isPromisified(fn)) {
return fn;
}
options = Object(options);
var receiver = options.context === undefined ? THIS : options.context;
var multiArgs = !!options.multiArgs;
var ret = promisify(fn, receiver, multiArgs);
util.copyDescriptors(fn, ret, propsFilter);
return ret;
};
复制代码
可以看到在判断了是否是函数的同时判断了fn是否已经被promise化过。 这里的参数以(fn,undefined)为例,调用的promisify函数传入的参数是(fn,{},false)
function promisify(callback, receiver, multiArgs) {
return makeNodePromisified(callback, receiver, undefined,
callback, null, multiArgs);
}
复制代码
promisify
实际是包装 了makeNodePromisified
这个函数,对参数进行了传递
var makeNodePromisified = canEvaluate
? makeNodePromisifiedEval
: makeNodePromisifiedClosure;
复制代码
makeNodePromisified
这个函数通过 canEvaluate
这个变量进行了调用函数的判断,这是一个判断运行环境是否是浏览器的变量。这里我们调用的是 makeNodePromisifiedClosure
这个函数
function makeNodePromisifiedClosure(callback, receiver, _, fn, __, multiArgs) {
var defaultThis = (function() {return this;})();
var method = callback;
if (typeof method === "string") {
callback = fn;
}
function promisified() {
var _receiver = receiver;
if (receiver === THIS) _receiver = this;
var promise = new Promise(INTERNAL);
promise._captureStackTrace();
var cb = typeof method === "string" && this !== defaultThis
? this[method] : callback;
var fn = nodebackForPromise(promise, multiArgs);//变成promise
try {
cb.apply(_receiver, withAppended(arguments, fn));//调用传入的cb
} catch(e) {
promise._rejectCallback(maybeWrapAsError(e), true, true);
}
if (!promise._isFateSealed()) promise._setAsyncGuaranteed();
return promise;
}
util.notEnumerableProp(promisified, "__isPromisified__", true);
return promisified;
}
复制代码
这里先把_receiver绑定在this上,调用nodebackForPromise返回一个promise赋给fn, nodebackForPromise的源码是
function nodebackForPromise(promise, multiArgs) {
return function(err, value) {
if (promise === null) return;
if (err) {
var wrapped = wrapAsOperationalError(maybeWrapAsError(err));
promise._attachExtraTrace(wrapped);
promise._reject(wrapped);
} else if (!multiArgs) {
promise._fulfill(value);
} else {
var $_len = arguments.length;var args = new Array(Math.max($_len - 1, 0)); for(var $_i = 1; $_i < $_len; ++$_i) {args[$_i - 1] = arguments[$_i];};
promise._fulfill(args);
}
promise = null;
};
}
复制代码
可以看到这里没有错误就调用 promise._fulfill(value)
,如果抛出了错误就调用 promise._reject处理
,上面 cb.apply(_receiver, withAppended(arguments, fn))
实际上可以看做 cb.apply(this,arguments,fn)
这里的fn即为 nodebackForPromise
返回的promise,funtion(err,value)这种形式也非常有node异步函数的特征。因此函数的的执行是在调用异步函数cb完成后调用回调函数fn这样就进入了promise中。即将异步函数promise化了。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网
猜你喜欢:- 存储过程 – 重新编译后,存储过程运行得很快
- 面试:谈谈你对 MyBatis 执行过程之 SQL 执行过程理解
- 死磕Android_App 启动过程(含 Activity 启动过程)
- 【PHP源码学习】关于$a=1整个过程的gdb过程与相关验证
- Spring的Property配置加载和使用过程及Environment的初始化过程
- [译]从输入URL到页面呈现的超详细过程——第二步:Tags转化成DOM的过程
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
大型分布式网站架构设计与实践
陈康贤 / 电子工业出版社 / 2014-9-1 / 79.00元
《大型分布式网站架构设计与实践》主要介绍了大型分布式网站架构所涉及的一些技术细节,包括SOA架构的实现、互联网安全架构、构建分布式网站所依赖的基础设施、系统稳定性保障和海量数据分析等内容;深入地讲述了大型分布式网站架构设计的核心原理,并通过一些架构设计的典型案例,帮助读者了解大型分布式网站设计的一些常见场景及遇到的问题。 作者结合自己在阿里巴巴及淘宝网的实际工作经历展开论述。《大型分布式网站......一起来看看 《大型分布式网站架构设计与实践》 这本书的介绍吧!