apply fix o collect

This commit is contained in:
Bassel 2022-11-24 14:47:06 +02:00
parent afbfffe424
commit fd226814d4

View File

@ -6,12 +6,11 @@ import { Readable } from 'stream';
export const collect = <T = unknown>(stream: Readable): Promise<T[]> => {
const chunks: T[] = [];
return new Promise((resolve) => {
stream.on('data', (chunk) => chunks.push(chunk));
stream.on('end', () => {
stream.destroy();
resolve(chunks);
});
return new Promise((resolve, reject) => {
stream
.on('data', (chunk) => chunks.push(chunk))
.on('close', () => resolve(chunks))
.on('error', reject);
});
};