Stream to Buffer
1 2 3 4 5 6 7 8
| function streamToBuffer(stream) { return new Promise((resolve, reject) => { let buffers = []; stream.on("error", reject); stream.on("data", data => buffers.push(data)); stream.on("end", () => resolve(Buffer.concat(buffers))); }); }
|
Buffer to Stream
1 2 3 4 5 6 7
| let Duplex = require("stream").Duplex; function bufferToStream(buffer) { let stream = new Duplex(); stream.push(buffer); stream.push(null); return stream; }
|
版权声明: 此文章版权归houxiaozhao所有,如有转载,请注明来自原作者
houxiaozhao
houxiaozhao的技术博客,专注于前端开发、Node.js、Web技术和JavaScript编程。分享技术心得,探讨开发经验,致力于提供高质量的技术文章和解决方案。
Follow Me