/// <reference types="node" />
import { AsyncMapper } from '@naturalcycles/js-lib';
import { ReadableTyped } from '../index';
import { StreamForEachOptions } from './stream.model';
/**
 * Wrapper around stream.pipeline() that will run Mapper for each of the items, respecting backpressure.
 */
export declare function streamForEach<IN>(streams: ReadableTyped<IN> | (NodeJS.ReadableStream | NodeJS.WritableStream)[], mapper: AsyncMapper<IN, void>, opt?: StreamForEachOptions<IN>): Promise<void>;