import { AgentEventStream } from '@multimodal/agent-interface';
/**
 * StreamAdapter - Adapts between standard events and streaming iterations
 *
 * This class handles the conversion between the event stream and
 * AsyncIterable for streaming responses.
 */
export declare class StreamAdapter {
    private eventStream;
    private logger;
    constructor(eventStream: AgentEventStream.Processor);
    /**
     * Create an AsyncIterable from the event stream for streaming back to the client
     *
     * @param abortSignal Optional abort signal to stop streaming
     * @returns An AsyncIterable of events
     */
    createStreamFromEvents(abortSignal?: AbortSignal): AsyncIterable<AgentEventStream.Event>;
    /**
     * Create a stream that's already aborted
     * Used when a request is aborted before streaming starts
     */
    createAbortedStream(): AsyncIterable<AgentEventStream.Event>;
    /**
     * Mark the stream as complete with a final event
     *
     * @param finalEvent The event that signals completion
     */
    completeStream(finalEvent: AgentEventStream.AssistantMessageEvent): void;
    /**
     * Mark the stream as aborted
     */
    abortStream(): void;
}
//# sourceMappingURL=stream-adapter.d.ts.map