关于 Generator 函数内的异步处理

Question

有一个上传头像的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;
            console.log('success');
        }
    } catch (err) {
        console.log('error' + err);
    }
}

悲剧来了，这里是异步执行的，总是输出success。

我尝试使用 thunkify 包装 part.pipe ，再用co执行，但不成功，而且我对thunkify和co总是不太清楚具体用法，也可能是我写得不对。

请帮忙解答一下，此处该如何使用yield同步，正确捕获错误，谢谢。