/**
 * Lightweight streaming event store for agents.
 * Agents publish partial responses so external subscribers can poll for streaming updates.
 */
export type StreamingEventType = 'start' | 'progress' | 'done' | 'error';
export interface StreamingEvent {
    sessionId: string;
    type: StreamingEventType;
    content: string;
    timestamp: string;
    metadata?: Record<string, any>;
}
declare class StreamingService {
    private events;
    private readonly maxEventsPerSession;
    publish(sessionId: string, event: Omit<StreamingEvent, 'sessionId' | 'timestamp'> & {
        timestamp?: string;
    }): void;
    consume(sessionId: string): StreamingEvent[];
    clear(sessionId: string): void;
}
export declare const streamingService: StreamingService;
export {};
//# sourceMappingURL=streaming.d.ts.map