import type { AgentAttachEvent, LogRecord, SubscriptionCloseReason, WatchEvent, WatchParams, WatchResult } from './generated/protocol.js';
import { Connection } from './connection.js';
import type { SubscriptionRegistration } from './connection.js';
import type { FrameRecord } from './frames.js';
export type SubscriptionClosedItem = {
    readonly type: 'closed';
    readonly reason: SubscriptionCloseReason;
};
export type WatchSubscriptionClosedItem = SubscriptionClosedItem & {
    readonly lastDeliveredCursor?: string | null;
};
export type SubscriptionItem<T> = {
    readonly type: 'event';
    readonly event: T;
} | SubscriptionClosedItem;
export type WatchSubscriptionItem = {
    readonly type: 'event';
    readonly runId: string;
    readonly cursor: string;
    readonly event: WatchEvent;
} | WatchSubscriptionClosedItem;
export interface Subscription<T> extends AsyncIterator<SubscriptionItem<T>>, AsyncIterable<SubscriptionItem<T>> {
    readonly subscriptionId: string;
    readonly retainedCount: number;
    cancel(): Promise<void>;
}
export interface WatchSubscription {
    readonly result: WatchResult;
    readonly stream: WatchSubscriptionStream;
}
type FrameParser<T> = (frame: FrameRecord) => SubscriptionItem<T>;
declare class SubscriptionStream<T> implements Subscription<T> {
    #private;
    protected readonly connection: Connection;
    protected readonly registration: SubscriptionRegistration;
    private readonly parse;
    constructor(connection: Connection, registration: SubscriptionRegistration, parse: FrameParser<T>);
    get subscriptionId(): string;
    get retainedCount(): number;
    [Symbol.asyncIterator](): this;
    next(): Promise<IteratorResult<SubscriptionItem<T>>>;
    return(): Promise<IteratorResult<SubscriptionItem<T>>>;
    throw(error?: unknown): Promise<IteratorResult<SubscriptionItem<T>>>;
    cancel(): Promise<void>;
}
export declare class LogsSubscriptionStream extends SubscriptionStream<LogRecord> {
    constructor(connection: Connection, registration: SubscriptionRegistration);
}
export declare class AgentAttachSubscriptionStream extends SubscriptionStream<AgentAttachEvent> {
    constructor(connection: Connection, registration: SubscriptionRegistration);
}
type WatchStreamInit = {
    readonly connection: Connection;
    readonly registration: SubscriptionRegistration;
    readonly result: WatchResult;
    readonly params: WatchParams;
    readonly lastSeenRunId?: string;
    readonly lastSeenCursor?: string;
};
export declare class WatchSubscriptionStream implements AsyncIterator<WatchSubscriptionItem>, AsyncIterable<WatchSubscriptionItem> {
    #private;
    constructor(init: WatchStreamInit);
    get subscriptionId(): string;
    get retainedCount(): number;
    get lastDeliveredCursor(): string | null | undefined;
    [Symbol.asyncIterator](): this;
    next(): Promise<IteratorResult<WatchSubscriptionItem>>;
    return(): Promise<IteratorResult<WatchSubscriptionItem>>;
    throw(error?: unknown): Promise<IteratorResult<WatchSubscriptionItem>>;
    cancel(): Promise<void>;
    reconnect(freshConnection: Connection): Promise<WatchSubscription>;
}
export {};