import type { APIAdapter, NormalizedRequest, NormalizedStreamChunk } from './types.js';
export declare class OpenAIAdapter implements APIAdapter {
    private getHeaders;
    private getAccountId;
    private socket;
    private readBuf;
    /** Cola de frames JSON ya parseados, para consumir desde receiveStream. */
    private pendingEvents;
    private streamClosed;
    private streamError;
    /** Notificador cuando hay algo nuevo que emitir (resolve de un waiter). */
    private notifyWaiter;
    /** Acumulador de argumentos de tool_use por item_id (arriban como deltas). */
    private toolCalls;
    constructor(getHeaders: () => Promise<Record<string, string>>, getAccountId: () => string | null);
    sendRequest(req: NormalizedRequest): Promise<void>;
    receiveStream(): AsyncIterable<NormalizedStreamChunk>;
    sendToolResult(_toolUseId: string, _result: string): Promise<void>;
    close(): void;
    private onData;
    private markClosed;
    /**
     * Consulta el endpoint REST `/backend-api/codex/usage` que ChatGPT expone para
     * Codex, convierte la respuesta al shape `SubscriptionUsage` y la inyecta en la
     * cola de eventos antes de cerrar el stream.
     *
     * Timeout de 2s: si el endpoint tarda, no bloqueamos al usuario — cerramos sin
     * información de uso.
     */
    private fetchSubscriptionAndClose;
    private notify;
    /** Traduce un evento `response.*` a uno o varios chunks normalizados. */
    private translateEvent;
}
//# sourceMappingURL=openai.d.ts.map