Tunggu panggilan balik fungsi async di acara stream.on ('data') terakhir

Anda dapat mengatasi masalah ini menggunakan perpustakaan async. Anda dapat menggunakan pola di bawah ini untuk aliran apa pun.

var AsyncLib = require('async');

var worker = function (payload, cb) {
    //do something with payload and call callback
    return cb();
};

var concurrency = 5;
var streamQueue = AsyncLib.queue(worker, concurrency);

var stream = //some readable stream;

stream.on('data', function(data) {
    //no need to pause and resume
    var payload = '//some payload';
    streamQueue.push(payload);
})
.on('end', function() {
    //register drain event on end and callback
    streamQueue.drain = function () {
        callback();
    };
});