关于 Generator 函数内的异步处理
有一个上传头像的generator函数
import parse from 'co-busboy';
avatar : function* (next){
...
let parts = parse(this);
let part;
while (part = yield parts) {
let stream = fs.createWriteStream(filename);
part.pipe;
console.log('success');
}
}
这样看上去好像没错,但是我在这里需要做错误处理,变成了:
avatar : function* (next){
...
try {
let parts = parse(this);
let part;
while (part = yield parts) {
let stream = fs.createWriteStream(filename);
part.pipe(stream);
console.log('success');
}
} catch (err) {
console.log('error' + err);
}
}
悲剧来了,这里是异步执行的,总是输出success。
我尝试使用 thunkify 包装 part.pipe ,再用co执行,但不成功,而且我对thunkify和co总是不太清楚具体用法,也可能是我写得不对。
请帮忙解答一下,此处该如何使用yield同步,正确捕获错误,谢谢。
5 回复
不要用偏函数化的方式了 co现在内部使用的Promise 而且那个偏函数化的函数我以前也用过 没成功 我后来是用的bluebird的fromNode把node回调转化为了Promise 然后yield 不过Promise方案很多 bluebird相对兼容还不错 你可以试试 自豪地采用 CNodeJS ionic
而且你那个库名是对的嘛 我说去看看源码的 自豪地采用 CNodeJS ionic
你的pipe为什么没有参数 自豪地采用 CNodeJS ionic
part.pipe是什么鬼
已经添加了参数,谢谢 @wenshiqi0 的解答