Node.js: bạn có thể sử dụng các chức năng không đồng bộ từ bên trong luồng không?

Question

xem xét như sau:

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 

Làm thế nào để biết khi nào dòng asyncFunction đã hoàn thành? Có cách nào để sử dụng các chức năng không đồng bộ từ bên trong luồng không?

Answer 1

Kiểm tra luồng biến đổi. Họ cung cấp cho bạn khả năng chạy mã async trên một đoạn, và sau đó gọi một cuộc gọi lại khi bạn đã hoàn tất. Dưới đây là các tài liệu: https://nodejs.org/api/stream.html#stream_transform_transform_chunk_encoding_callback

Là một ví dụ đơn giản, bạn có thể làm điều gì đó như:

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)