import { BaseCommunicationProtocol, AgentRequestHandler } from "../ICommunication";
export declare enum StreamType {
    RAW = "raw",
    OBSERVE = "observe",
    SESSION = "session"
}
export declare enum ClientFormat {
    SSE = "sse",// Server-Sent Events (default for web)
    RAW_JSON = "raw"
}
export declare class StreamingProtocol extends BaseCommunicationProtocol {
    private server?;
    private port;
    private host;
    private streams;
    private keepaliveIntervals;
    private readonly encoder;
    constructor(handler: AgentRequestHandler, port?: number, host?: string);
    start(): Promise<void>;
    private handleRequest;
    private handleRawStream;
    private handleObservabilityStream;
    private handleSessionStream;
    private cleanupConnection;
    broadcast(data: string, sessionId?: string): void;
    sendResponseComplete(sessionId: string): void;
    sendStreamError(sessionId: string, error: string): void;
    stop(): Promise<void>;
}