An eventier stream handler

not-so-simple-stream-example.ts

import { Readable } from 'stream';
import { gzip } from 'zlib';

export async function notSoSimpleStreamExample(stream: Readable) {
	return new Promise((resolve, reject) => {
		const data: Array<Promise<Buffer>> = [];
		stream.on('data', info => {
			data.push(new Promise((resolve, reject) => {
				gzip(info, (error, result) => {
					if (error) {
						reject(error);
					} else {
						resolve(result);
					}
				})
			}));
		});
		stream.on('end', () => {
			resolve(Promise.all(data));
		});
		stream.on('error', error => {
			reject(error);
		});
	});
}