import type { AgUiClient, AllEventType, Id, ConversationDoc, MessageDoc } from '../types';
type Handler<E extends AllEventType> = (payload: any) => void;
export interface SseAgClientOptions {
    baseUrl: string;
    headers?: Record<string, string>;
    paths?: Partial<{
        conversations: string;
        messages: string;
        autoCreate: string;
    }>;
}
export declare class SseAgClient implements AgUiClient {
    private baseUrl;
    private headers;
    private paths;
    private listeners;
    private activeStreams;
    constructor(options: SseAgClientOptions);
    on<E extends AllEventType>(type: E, handler: Handler<E>): () => void;
    off<E extends AllEventType>(type: E, handler: Handler<E>): void;
    emit<E extends AllEventType>(type: E, payload: any): void;
    createConversation(title?: string, metadata?: Record<string, unknown>): Promise<ConversationDoc>;
    listConversations(): Promise<ConversationDoc[]>;
    getConversation(id: Id): Promise<ConversationDoc>;
    updateConversation(id: Id, updates: Partial<ConversationDoc>): Promise<ConversationDoc>;
    archiveConversation(id: Id): Promise<void>;
    sendMessage(conversationId: Id | null, text: string, options?: {
        attachments?: Id[];
        metadata?: Record<string, unknown>;
        onEvent?: (event: {
            type: string;
            data: any;
        }) => void;
    }): Promise<MessageDoc>;
    private parseSSEStream;
    private parseSSEMessage;
    getMessages(conversationId: Id): Promise<MessageDoc[]>;
    cancelMessage(conversationId: Id, messageId: Id): Promise<void>;
    close(): void;
}
export default SseAgClient;
//# sourceMappingURL=sse.d.ts.map