Stream to buffer

stream-to-buffer.ts

import { Writable } from "stream";


export const streamAsPromise = (readable: Readable): Promise<Buffer> => {
  const result: Array<Buffer> = [];
  const w = new Writable({
    write(chunk, encoding, callback) {
      result.push(chunk);
      callback();
    },
  });
  readable.pipe(w);
  return new Promise((resolve, reject) => {
    w.on("finish", resolve);
    w.on("error", reject);
  }).then(() => Buffer.concat(result));
};