import "../../_dnt.polyfills.js";
import { type $Callback } from "../createSignal.js";
export interface $AbortAble {
    signal?: AbortSignal;
}
export declare const streamRead: <T extends unknown>(stream: ReadableStream<T>, options?: $AbortAble) => AsyncGenerator<Awaited<T>, void, unknown>;
export declare const binaryStreamRead: (stream: ReadableStream<Uint8Array>, options?: $AbortAble) => AsyncGenerator<Uint8Array, void, unknown> & {
    available: () => Promise<number>;
    readBinary: (size: number) => Promise<Uint8Array>;
    readInt: () => Promise<number>;
};
export interface $StreamReadAllOptions<I, T, R> {
    map?: (item: I) => T;
    complete?: (maps: T[]) => R;
}
export declare const streamReadAll: <I, T, R>(stream: ReadableStream<I>, options?: $StreamReadAllOptions<I, T, R>) => Promise<{
    maps: T[];
    result: R;
}>;
export declare const streamReadAllBuffer: (stream: ReadableStream<Uint8Array>) => Promise<Uint8Array>;
export declare class ReadableStreamOut<T> {
    readonly strategy?: QueuingStrategy<T> | undefined;
    constructor(strategy?: QueuingStrategy<T> | undefined);
    controller: ReadableStreamDefaultController<T>;
    stream: ReadableStream<T>;
    private _on_cancel_signal?;
    get onCancel(): (cb: $Callback<[any]>) => import("../createSignal.js").$OffListener;
    private _on_pull_signal?;
    get onPull(): (cb: $OnPull) => import("../createSignal.js").$OffListener;
}
export type $OnPull = () => unknown;
//# sourceMappingURL=readableStreamHelper.d.ts.map