节点流 - 进行同步以在流完成后返回数组

Question

我写这个函数是为了从流中提取文件列表。它可以工作，但是流是异步的，并且在流完成之前返回files数组。我真的不想使用承诺库...尽量保持代码轻量级。流完成后如何返回files数组？

function fileList(source) {
    var files = [];
    source.pipe(through2.obj(function(obj, enc, next) {
        file = obj.history[0].split("/").pop();
        files.push(file);
        next();
    }));
    return files;
}

Answer 1

提供回调，而不是从函数返回值：

function fileList(source, callback) {
  var files = [];
  source.pipe(through2.obj(function(obj, enc, next) {
    file = obj.history[0].split("/").pop();
    files.push(file);
    next();
  }, function(flushcb) {
    flushcb();
    callback(null, files);
  }));
}
// ...
fileList(stream, function(err, files) {
  if (err) throw err;
  // use `files` here ...
});