import { AgentEventStream, AgentSingleLoopReponse } from '@multimodal/agent-interface';
/**
 * Implementation of the EventStream processor
 */
export declare class AgentEventStreamProcessor implements AgentEventStream.Processor {
    private events;
    private options;
    private subscribers;
    private logger;
    constructor(options?: AgentEventStream.ProcessorOptions);
    /**
     * Create a new event with default properties
     */
    createEvent<T extends AgentEventStream.EventType>(type: T, data: Omit<AgentEventStream.EventPayload<T>, keyof AgentEventStream.BaseEvent>): AgentEventStream.EventPayload<T>;
    /**
     * Send an event to the stream
     */
    sendEvent(event: AgentEventStream.Event): void;
    /**
     * Get all events in the stream
     */
    getEvents(filter?: AgentEventStream.EventType[], limit?: number): AgentEventStream.Event[];
    /**
     * Get events by their type
     */
    getEventsByType(types: AgentEventStream.EventType[], limit?: number): AgentEventStream.Event[];
    /**
     * Get the latest assistant response to be used for the next message
     */
    getLatestAssistantResponse(): AgentSingleLoopReponse | null;
    /**
     * Get tool results since the last assistant message
     */
    getLatestToolResults(): {
        toolCallId: string;
        toolName: string;
        content: any;
    }[];
    /**
     * Clear all events from the stream
     */
    clear(): void;
    /**
     * Subscribe to new events
     */
    subscribe(callback: (event: AgentEventStream.Event) => void): () => void;
    /**
     * Subscribe to specific event types
     */
    subscribeToTypes(types: AgentEventStream.EventType[], callback: (event: AgentEventStream.Event) => void): () => void;
    /**
     * Subscribe to streaming events only
     */
    subscribeToStreamingEvents(callback: (event: AgentEventStream.AssistantStreamingMessageEvent | AgentEventStream.AssistantStreamingThinkingMessageEvent) => void): () => void;
}
//# sourceMappingURL=event-stream.d.ts.map