我想将一些readeableStreams压缩为writableStream。
目的是在内存中完成所有操作,而不是在磁盘上创建实际的zip文件。

为此,我正在使用存档器

        let bufferOutput = Buffer.alloc(5000);
        let archive = archiver('zip', {
            zlib: { level: 9 } // Sets the compression level.
        });
        archive.pipe(bufferOutput);
        archive.append(someReadableStread, { name: test.txt});
        archive.finalize();


我在行archive.pipe(bufferOutput);上收到错误消息。

这是错误:“ dest.on不是函数”

我究竟做错了什么?
谢谢

更新:

我正在运行以下代码进行测试,并且未正确创建ZIP文件。我想念什么?

const   fs = require('fs'),
    archiver = require('archiver'),
    streamBuffers = require('stream-buffers');

let outputStreamBuffer = new streamBuffers.WritableStreamBuffer({
    initialSize: (1000 * 1024),   // start at 1000 kilobytes.
    incrementAmount: (1000 * 1024) // grow by 1000 kilobytes each time buffer overflows.
});

let archive = archiver('zip', {
    zlib: { level: 9 } // Sets the compression level.
});
archive.pipe(outputStreamBuffer);

archive.append("this is a test", { name: "test.txt"});
archive.finalize();

outputStreamBuffer.end();

fs.writeFile('output.zip', outputStreamBuffer.getContents(), function() { console.log('done!'); });

最佳答案

在您的更新示例中,我认为您正在尝试在编写内容之前获取内容。

进入完成事件,然后获取内容。

outputStreamBuffer.on('finish', () => {
  // Do something with the contents here
  outputStreamBuffer.getContents()
})

09-25 16:14