关于 Generator 函数内的异步处理
发布于 9 年前 作者 timnity 3432 次浏览 最后一次编辑是 8 年前 来自 问答

有一个上传头像的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 的解答

回到顶部