理解了co的核心代码就理解了koa的流程控制
var ctx = this;
var args = slice.call(arguments, 1);
一开始保存上下文,把arguments的length属性去掉,剩余的参数转数组就是gen的参数
再来看return的promise内的代码
if (typeof gen === 'function') gen = gen.apply(ctx, args);
if (!gen || typeof gen.next !== 'function') return resolve(gen);
先判断gen是不是generator function,如果是就转为generator,相当于gen = new gen;
转为generator之后就可以调用gen.next()了;
onFulfilled();
这是进入循环调用链的入口
function onFulfilled(res) {
var ret;
try {
ret = gen.next(res);
} catch (e) {
return reject(e);
}
next(ret);
}
function onRejected(err) {
var ret;
try {
ret = gen.throw(err);
} catch (e) {
return reject(e);
}
next(ret);
}
function next(ret) {
if (ret.done) return resolve(ret.value);
var value = toPromise.call(ctx, ret.value);
if (value && isPromise(value)) return value.then(onFulfilled, onRejected);
return onRejected(new TypeError('You may only yield a function, promise, generator, array, or object, '
+ 'but the following object was passed: "' + String(ret.value) + '"'));
}
ret是gen.next后的{value:''done:''}对象,value是yield后的表达式,done是执行状态.
判断ret.done是否为true来确定是否需要再执行下去.为true时,说明已经是generator的最后一步,promise转为resolve.不为true时,将yield后的表达式转化为promise.
先判断是否转化为了promise,转化成功,就通过value.then(onFulfilled, onRejected)
执行onFulfilled或onRejected,再次调用next(),实现循环调用.
当value不能转为promise时,抛出错误,promise转为reject,停止继续运行.
下面写一个例子简单分析一下:
var co = require('co');
var fs = require('fs');
function thunkRead(name) {
return function (cb) {
fs.readFile(name, function (err, file) {
cb(err, file);
});
}
}
co(function *() {
var file = yield thunkRead("package.json");
console.log(file);
return file;
}).then(function (file) {
console.log(file);
});
通过上面这段代码来看一下co的整个流程
先模拟一个名为thunkRead的thunk函数,再看co里面的代码,co里面是一个generator function,gen = gen.apply(ctx, args);
通过这一句转化为了generator。
再进入onFulfilled()函数,第一个gen.next()之后ret是 { value: [Function], done: false }
将ret传入next()中,done为false,所以toPromise,value是function,所以thunkToPromise.
function thunkToPromise(fn) {
var ctx = this;
return new Promise(function (resolve, reject) {
fn.call(ctx, function (err, res) {
if (err) return reject(err);
if (arguments.length > 2) res = slice.call(arguments, 1);
resolve(res);
});
});
}
因为fn是thunk函数,参数只有一个回调函数, fn.call(ctx, function (err, res) {});
直接调用resolve,在上面的例子中是resolve(file);
然后回到next()中,此时已经是一个promise对象,调用value的then方法,onFulfilled的参数就是file,再运行gen.next(file),将上一步yield的结果file传入generator,因为在例子中最后return了file, ret是 { value:<Buffer ...>, done: true }
最后不返回值的话应该是 { value: undefined, done: true }
, 再进入到next()中, 此时done已经为true,说明已经是generator的最后一步,resolve(value);
co中的代码已经执行结束,因为co也是一个promise, 最后resolve(value),所有可以在then方法中得到这个value.
补充下toPromise支持转化thunks,array,objects,generators,generator functions.
所以可以yieldable的是以下6种: