import { Response } from 'express';
import { r as ResponseStreamEvent, j as ResponseContext, C as CreateResponse, b as ResponseObject } from '../types-Dvs2F85g.js';
import 'node:http';
import '@cuylabs/agent-foundry-agentserver-core';

interface SseEncoderState {
    sequenceNumber: number;
}
declare function startResponsesSseResponse(res: Response): void;
declare function createSseEncoderState(): SseEncoderState;
declare function encodeSseEvent(event: ResponseStreamEvent, state?: SseEncoderState): string;
declare function encodeKeepAliveComment(comment?: string): string;

type TextSource = string | (() => string | Promise<string>) | AsyncIterable<string> | Iterable<string>;
declare class TextResponse implements AsyncIterable<ResponseStreamEvent> {
    private readonly context;
    private readonly request;
    private readonly options;
    constructor(context: ResponseContext, request: CreateResponse, options: {
        text: TextSource;
        configure?: (response: ResponseObject) => void;
    });
    [Symbol.asyncIterator](): AsyncIterator<ResponseStreamEvent>;
    private generate;
}

export { type SseEncoderState, TextResponse, type TextSource, createSseEncoderState, encodeKeepAliveComment, encodeSseEvent, startResponsesSseResponse };