///
import { Readable, Writable, Duplex } from 'stream';
import { Cloneable } from 'cloneable-readable';
export declare function zip(array1: T[], array2: U[]): [T, U][];
export declare function clones>(stream: T, count: number): T[];
export declare function connect(source: Readable | Cloneable, target: Writable | Writable[], debug?: boolean): Promise;
export declare function makeDestroyedStream(error: Error): Duplex;
export declare function lazyWriteStream(createStream: () => Writable): Writable;
declare const downstream = "downstream";
export declare type DownstreamError = Error & {
direction: typeof downstream;
};
export declare function isDownstreamError(x: unknown): x is DownstreamError;
export declare function toDownstreamError(error: Error): DownstreamError;
declare const upstream = "upstream";
export declare type UpstreamError = Error & {
direction: typeof upstream;
};
export declare function isUpstreamError(x: unknown): x is UpstreamError;
export declare function toUpstreamError(error: Error): UpstreamError;
export {};