export declare function consumeStream<E, R>(stream: ReadableStream<E>, cb: (msg: E) => R): Promise<R[]>;
export declare function processStream<E, CTX = object>(stream: ReadableStream<E>, cb: (msg: E, ctx: CTX) => Promise<void> | void, ctx?: CTX): Promise<void>;
export interface StepCfg<CTX = object> {
    readonly chunkSize: number;
    readonly setTimeoutFn: (fn: () => void, delay: number) => void;
    readonly ctx: CTX;
}
export declare function consumeIterator<T, R>(iter: IterableIterator<T> | AsyncIterableIterator<T>, cb: (msg: T) => R, params?: Partial<StepCfg<R[]>>): Promise<R[]>;
export declare function processIterator<T, CTX = object>(iter: IterableIterator<T> | AsyncIterableIterator<T>, cb: (msg: T) => Promise<void> | void, params?: Partial<StepCfg<CTX>>): Promise<void>;
//# sourceMappingURL=consume.d.ts.map