Function streamToBuffer

packages/core/src/common/utils/stream-to-buffer.ts:8–15

(stream: NodeJS.ReadableStream)

 * @returns {Promise<Buffer>} The concatenated buffer
 */
export async function streamToBuffer(stream: NodeJS.ReadableStream): Promise<Buffer> {
  return await new Promise((resolve, reject) => {
    const chunks: Buffer[] = [];
    stream.on('data', (chunk: Buffer) => chunks.push(chunk));
    stream.on('error', reject);
    stream.on('end', () => resolve(Buffer.concat(chunks)));
  });
}