节点流 - 当流完成时进行同步以返回数组。

Question

我编写了这个函数来从流中提取文件列表。它可以工作，但是流是异步的，并且在流完成之前返回 files 数组。我真的不想使用 Promise 库......尽量保持代码简洁。流完成后如何返回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 ...
});