import { Request, Response } from 'express';
import { StreamEvent } from '../types/stream.js';
import '../types/memory.js';
import '../types/connector.js';

type SSEStreamOptions = {
    logLabel: string;
    userId: string;
    logContext?: Record<string, unknown>;
    onThreadId?: (threadId: string) => void;
    onThinkingProcess?: (threadId: string, data: Extract<StreamEvent, {
        event: "thinking_process";
    }>["data"]) => Promise<void> | void;
    /**
     * Called once the stream has been fully consumed with no error and no
     * client-initiated abort — i.e. on successful completion only.
     */
    onComplete?: () => Promise<void> | void;
    setup: (signal: AbortSignal) => Promise<AsyncIterable<StreamEvent>>;
};
declare function streamEventsToSSE(req: Request, res: Response, options: SSEStreamOptions): Promise<void>;

export { type SSEStreamOptions, streamEventsToSSE };