stream.ts 352 B

1234567891011121314
  1. export const convertStreamToBuffer = (stream: any): Promise<Buffer> => {
  2. return new Promise((resolve, reject) => {
  3. const buffer: Uint8Array[] = [];
  4. stream.on('data', (chunk: Uint8Array) => {
  5. buffer.push(chunk);
  6. });
  7. stream.on('end', () => resolve(Buffer.concat(buffer)));
  8. stream.on('error', err => reject(err));
  9. });
  10. };