Node.js: Eşzamansız işlevleri akımların içinden kullanabilir misiniz?

Question

düşünün:

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 tamamlandığında nasıl akışı biliyor? Eşzamanlı işlevleri akımların içinden kullanmanın bir yolu var mı?

Answer 1

Dönüştürme akışlarını gözden geçirin. Size, bir öbek üzerinde uyumsuz kod çalıştırma yeteneğini verir ve işiniz bittiğinde bir geri arama çağrısı yapın. Ben dokümantasyon üzerinde iki parametre göstermiyor çünkü akışı geri arama nasıl işleyeceğini emin değilim

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)