import type OpenAI from "../index.mjs"; import type { RequestOptions } from "../internal/request-options.mjs"; import type { ChatCompletion, ChatCompletionCreateParams, ChatCompletionMessage, ChatCompletionMessageFunctionToolCall, ChatCompletionMessageParam, ParsedChatCompletion } from "../resources/chat/completions.mjs"; import type { CompletionUsage } from "../resources/completions.mjs"; import type { ChatCompletionToolRunnerParams } from "./ChatCompletionRunner.mjs"; import type { ChatCompletionStreamingToolRunnerParams } from "./ChatCompletionStreamingRunner.mjs"; import { BaseEvents, EventStream } from "./EventStream.mjs"; import { type BaseFunctionsArgs } from "./RunnableFunction.mjs"; export interface RunnerOptions extends RequestOptions { /** How many requests to make before canceling. Default 10. */ maxChatCompletions?: number; } export declare class AbstractChatCompletionRunner extends EventStream { #private; protected _chatCompletions: ParsedChatCompletion[]; messages: ChatCompletionMessageParam[]; protected _addChatCompletion(this: AbstractChatCompletionRunner, chatCompletion: ParsedChatCompletion): ParsedChatCompletion; protected _addMessage(this: AbstractChatCompletionRunner, message: ChatCompletionMessageParam, emit?: boolean): void; /** * @returns a promise that resolves with the final ChatCompletion, or rejects * if an error occurred or the stream ended prematurely without producing a ChatCompletion. */ finalChatCompletion(): Promise>; /** * @returns a promise that resolves with the content of the final ChatCompletionMessage, or rejects * if an error occurred or the stream ended prematurely without producing a ChatCompletionMessage. */ finalContent(): Promise; /** * @returns a promise that resolves with the the final assistant ChatCompletionMessage response, * or rejects if an error occurred or the stream ended prematurely without producing a ChatCompletionMessage. */ finalMessage(): Promise; /** * @returns a promise that resolves with the content of the final FunctionCall, or rejects * if an error occurred or the stream ended prematurely without producing a ChatCompletionMessage. */ finalFunctionToolCall(): Promise; finalFunctionToolCallResult(): Promise; totalUsage(): Promise; allChatCompletions(): ChatCompletion[]; protected _emitFinal(this: AbstractChatCompletionRunner): void; protected _createChatCompletion(client: OpenAI, params: ChatCompletionCreateParams, options?: RequestOptions): Promise>; protected _runChatCompletion(client: OpenAI, params: ChatCompletionCreateParams, options?: RequestOptions): Promise; protected _runTools(client: OpenAI, params: ChatCompletionToolRunnerParams | ChatCompletionStreamingToolRunnerParams, options?: RunnerOptions): Promise; } export interface AbstractChatCompletionRunnerEvents extends BaseEvents { functionToolCall: (functionCall: ChatCompletionMessageFunctionToolCall.Function) => void; message: (message: ChatCompletionMessageParam) => void; chatCompletion: (completion: ChatCompletion) => void; finalContent: (contentSnapshot: string) => void; finalMessage: (message: ChatCompletionMessageParam) => void; finalChatCompletion: (completion: ChatCompletion) => void; finalFunctionToolCall: (functionCall: ChatCompletionMessageFunctionToolCall.Function) => void; functionToolCallResult: (content: string) => void; finalFunctionToolCallResult: (content: string) => void; totalUsage: (usage: CompletionUsage) => void; } //# sourceMappingURL=AbstractChatCompletionRunner.d.mts.map