import { AgentEventStream } from '@agent-tars/core';
/**
 * Implement event stream bridging to forward Agent's native events to the client
 */
export declare class EventStreamBridge {
    private subscribers;
    /**
     * Subscribe to events
     * @param handler event processing function
     */
    subscribe(handler: (type: string, data: any) => void): void;
    /**
     * Unsubscribe event
     * @param handler event processing function
     */
    unsubscribe(handler: (type: string, data: any) => void): void;
    /**
     * Publish event
     * @param type event type
     * @param data event data
     */
    emit(type: string, data: any): void;
    /**
     * Event stream manager connected to Agent
     * @param agentEventStream Agent's event stream manager
     * @returns Unsubscribe function
     */
    connectToAgentEventStream(agentEventStream: AgentEventStream.Processor): () => void;
}
//# sourceMappingURL=event-stream.d.ts.map