/// 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 {};