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;
}