有一个上传头像的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同步，正确捕获错误，谢谢。