Node.js:你可以在流中使用异步函数吗?

11 浏览
0 Comments

Node.js:你可以在流中使用异步函数吗?

请考虑以下内容:

var asyncFunction = function(data, callback) {
  doAsyncyThing(function(data){
    // 做一些事情
    return callback(err)
  })
}
fs.createReadStream('eupmc_lite_metadata_2016_04_15.json')
  .pipe(JSONstream.parse())
  .on('data', asyncFunction)   // <- 如何让asyncFunction在继续之前完成

流如何知道asyncFunction何时完成?有没有办法在流中使用异步函数?

0