Gulp：如何从一组流的承诺中创建一个流？

Question

我有一个由异步函数启动的任务列表。我最终得到了一系列流的承诺。我需要将这些流合并为一个流并将其返回给 Gulp。以下是我想出的。这有点笨拙。有没有更好的方法来做到这一点？

return es.readable(function(count, callback) {
    var dest = this;
    promise.then(function(streams) {
        es.merge.apply(null, streams)
            .on('end', dest.emit.bind(dest, 'end'))
            .on('data', dest.emit.bind(dest, 'data'))
            .on('error', dest.emit.bind(dest, 'error'));
    });
});

Answer 1

es.merge 返回可读流。
没有理由再创建一个 es.readable。
我有很长一段时间没有 node.js 经验，但我觉得我写的东西有帮助:)

// async way
function merged(promise, next) {
    promise.then(function(streams) {
        next(null, es.merge.apply(null, streams));
    }, next);
}
// like a promise
function merged(promise) {
  return {
    then: function(ok, fail) {
      promise.then(function(streams) {
        ok(es.merge.apply(null, streams));
      }, fail);
    }
  }; 
}

用法：

merged(promise, function(err, stream){stream.pipe(anyWritable);}); // async
merged(promise).then(function(stream){stream.pipe(anyWritable);}); // then