export function makeQueue(): import("./types.js").AsyncQueue; export function makeStream(acks: import("./types.js").AsyncSpring>, data: import("./types.js").AsyncSink>): { /** * @param {TWrite} value */ next(value: TWrite): Promise>; /** * @param {TWriteReturn} value */ return(value: TWriteReturn): Promise>; /** * @param {Error} error */ throw(error: Error): Promise>; [Symbol.asyncIterator](): /*elided*/ any; }; export function makePipe(): { /** * @param {TWrite} value */ next(value: any): Promise>; /** * @param {TWriteReturn} value */ return(value: any): Promise>; /** * @param {Error} error */ throw(error: Error): Promise>; [Symbol.asyncIterator](): /*elided*/ any; }[]; export function pump(writer: import("./types.js").Stream, reader: import("./types.js").Stream, primer: TWrite): Promise; export function prime(generator: AsyncGenerator, primer: TWrite): { /** @param {TWrite} value */ next(value: TWrite): Promise>; /** @param {TReturn} value */ return(value: TReturn): Promise>; /** @param {Error} error */ throw(error: Error): Promise>; }; export function mapReader(reader: import("./types.js").Reader, transform: (value: TIn) => TOut): import("./types.js").Reader; export function mapWriter(writer: import("./types.js").Writer, transform: (value: TIn) => TOut): import("./types.js").Writer; //# sourceMappingURL=index.d.ts.map