import { type AnySchema, type Static } from "../../toolcraft-schema/dist/index.js";
export type StreamStatusType = "connected" | "progress" | "reconnecting";
export interface StreamStatusEvent {
    type: StreamStatusType;
    message?: string;
}
export interface StreamConsumerOptions {
    signal?: AbortSignal;
    onStatus?: (event: StreamStatusEvent) => void;
}
export interface ToolcraftStream<TEvent> extends AsyncIterable<TEvent> {
    readonly signal: AbortSignal;
    cancel(reason?: unknown): Promise<void>;
}
export interface ManagedStreamOptions<TSchema extends AnySchema> extends StreamConsumerOptions {
    eventSchema: TSchema;
    create(signal: AbortSignal, status: (event: StreamStatusEvent) => void): Promise<AsyncIterable<Static<TSchema>>>;
}
export declare function createManagedStream<TSchema extends AnySchema>(options: ManagedStreamOptions<TSchema>): ToolcraftStream<Static<TSchema>>;