如何在node.js中制作传输流?

How make transfer stream in node.js?

我使用 JsZip 和 exceljs 包。 ExcelJs 可以将 excel doc 写入 node.js 流,jszip 可以从流中读取文件并将其添加到存档中。我如何在它之间进行流传输以便于使用它?我做了这个解决方案,但我认为它的拐杖不好...

const stream2 = new Writable();
  stream2.result = [];
  stream2._write = function (chunk, enc, next) {
  this.result.push(chunk);
  next();
 };

  const stream1 = new Readable();
  stream1._read = function () {
    stream1.push(stream2.result.shift() || null);
  };

  let promise = new Promise((resolve, reject) => {
    excelDoc.write(stream2).then(() => {
      zip.file('excelDoc.xlsx', stream1);
      resolve(true);
    });
  });

我不太明白你想做什么,但看起来你正在重新发明 Duplex Stream or Transform Stream。这些是可读和可写的流。

转换流是双工流,其中输出在某种程度上与输入相关,我们可以将它们用于您正在尝试做的事情(我认为):

const stream = require('stream');

const transformStream = new stream.Transform({
  transform: (data, encoding, callback) => callback(null, data)
});

let promise = new Promise((resolve, reject) => {
  excelDoc.write(transformStream).then(() => {
    zip.file('excelDoc.xlsx', transformStream);
    resolve(true);
  });
});

旁注:通常你会做这样的事情:

inputStream.pipe(excelDoc).pipe(zipStream).pipe(outputStream);

但我发现你的依赖项都不支持这种语法。