import { AssistantStream } from "https://deno.land/x/openai@v4.62.1/lib/AssistantStream.ts";
Methods
protected
_createAssistantStream(): Promise<Run>protected
_createThreadAssistantStream(): Promise<Run>protected
_createToolAssistantStream(run: Runs,
threadId: string,
runId: string,
params: RunSubmitToolOutputsParamsStream,
options?: Core.RequestOptions,
protected
_fromReadableStream(readableStream: ReadableStream, options?: Core.RequestOptions): Promise<Run>protected
_runAssistantStream(): Promise<Run>protected
_runToolAssistantStream(threadId: string,
runId: string,
runs: Runs,
params: RunSubmitToolOutputsParamsStream,
options?: Core.RequestOptions,
protected
_threadAssistantStream(): Promise<Run>currentEvent(): AssistantStreamEvent | undefined
currentMessageSnapshot(): Message | undefined
currentRun(): Run | undefined
currentRunStepSnapshot(): Runs.RunStep | undefined
finalMessages(): Promise<Message[]>
finalRunSteps(): Promise<Runs.RunStep[]>
[Symbol.asyncIterator](): AsyncIterator<AssistantStreamEvent>
Static Methods
accumulateDelta(acc: Record<string, any>, delta: Record<string, any>): Record<string, any>
createToolAssistantStream()
threadId: string,
runId: string,
runs: Runs,
params: RunSubmitToolOutputsParamsStream,
options: RequestOptions | undefined,
fromReadableStream(stream: ReadableStream): AssistantStream