Node.js：ストリーム内から非同期関数を使用できますか？

Question

は、次のことを考えてみましょう：

var asyncFunction = function(data, callback) { 
    doAsyncyThing(function(data){ 
    // do some stuff 
    return callback(err) 
    }) 
} 
fs.createReadStream('eupmc_lite_metadata_2016_04_15.json') 
    .pipe(JSONstream.parse()) 
    .on('data', asyncFunction) // <- how to let asyncFunction complete before continuing 

asyncFunctionが完了したときにどのようにストリームが知っているのですか？ストリーム内から非同期関数を使用する方法はありますか？

Answer 1

変換ストリームを確認してください。チャンクで非同期コードを実行し、終了したらコールバックを呼び出すことができます。私は、ドキュメントは上の2つのパラメータが表示されないので、ストリームは、コールバックを処理するかどうかはわかりません

const Transform = require('stream').Transform 
class WorkerThing extends Transform { 
    _transform(chunk, encoding, cb) { 
     asyncFunction(chunk, cb) 
    } 
} 

const workerThing = new WorkerThing() 

fs.createReadStream('eupmc_lite_metadata_2016_04_15.json') 
.pipe(JSONstream.parse()) 
.pipe(workerThing)