export function consumeStream(stream: ReadableStreamEvents<unknown>): Promise<undefined>;
export function consumeStream<T, R = T>(stream: ReadableStreamEvents<T>, reducer?: IReducer<T, R>): Promise<R | undefined> {
const chunks: T[] = [];
listenStream(stream, {
onData: chunk => {
if (reducer) {
chunks.push(chunk);
}
},
if (reducer) {
reject(error);