如何在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);
但我发现你的依赖项都不支持这种语法。
我使用 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);
但我发现你的依赖项都不支持这种语法。