@@ -8,28 +8,28 @@ import {
8
8
TextDelta ,
9
9
MessageDelta ,
10
10
MessageContent ,
11
- } from 'openai /resources/beta/threads/messages' ;
12
- import * as Core from 'openai /core' ;
13
- import { RequestOptions } from 'openai /core' ;
11
+ } from '.. /resources/beta/threads/messages' ;
12
+ import * as Core from '.. /core' ;
13
+ import { RequestOptions } from '.. /core' ;
14
14
import {
15
15
Run ,
16
16
RunCreateParamsBase ,
17
17
RunCreateParamsStreaming ,
18
18
Runs ,
19
19
RunSubmitToolOutputsParamsBase ,
20
20
RunSubmitToolOutputsParamsStreaming ,
21
- } from 'openai /resources/beta/threads/runs/runs' ;
22
- import { type ReadableStream } from 'openai /_shims/index' ;
23
- import { Stream } from 'openai /streaming' ;
24
- import { APIUserAbortError , OpenAIError } from 'openai /error' ;
21
+ } from '.. /resources/beta/threads/runs/runs' ;
22
+ import { type ReadableStream } from '.. /_shims/index' ;
23
+ import { Stream } from '.. /streaming' ;
24
+ import { APIUserAbortError , OpenAIError } from '.. /error' ;
25
25
import {
26
26
AssistantStreamEvent ,
27
27
MessageStreamEvent ,
28
28
RunStepStreamEvent ,
29
29
RunStreamEvent ,
30
- } from 'openai /resources/beta/assistants' ;
31
- import { RunStep , RunStepDelta , ToolCall , ToolCallDelta } from 'openai /resources/beta/threads/runs/steps' ;
32
- import { ThreadCreateAndRunParamsBase , Threads } from 'openai /resources/beta/threads/threads' ;
30
+ } from '.. /resources/beta/assistants' ;
31
+ import { RunStep , RunStepDelta , ToolCall , ToolCallDelta } from '.. /resources/beta/threads/runs/steps' ;
32
+ import { ThreadCreateAndRunParamsBase , Threads } from '.. /resources/beta/threads/threads' ;
33
33
import { BaseEvents , EventStream } from './EventStream' ;
34
34
35
35
export interface AssistantStreamEvents extends BaseEvents {
@@ -192,7 +192,7 @@ export class AssistantStream
192
192
runs : Runs ,
193
193
params : RunSubmitToolOutputsParamsStream ,
194
194
options : RequestOptions | undefined ,
195
- ) {
195
+ ) : AssistantStream {
196
196
const runner = new AssistantStream ( ) ;
197
197
runner . _run ( ( ) =>
198
198
runner . _runToolAssistantStream ( threadId , runId , runs , params , {
@@ -238,7 +238,7 @@ export class AssistantStream
238
238
params : ThreadCreateAndRunParamsBaseStream ,
239
239
thread : Threads ,
240
240
options ?: RequestOptions ,
241
- ) {
241
+ ) : AssistantStream {
242
242
const runner = new AssistantStream ( ) ;
243
243
runner . _run ( ( ) =>
244
244
runner . _threadAssistantStream ( params , thread , {
@@ -254,7 +254,7 @@ export class AssistantStream
254
254
runs : Runs ,
255
255
params : RunCreateParamsBaseStream ,
256
256
options ?: RequestOptions ,
257
- ) {
257
+ ) : AssistantStream {
258
258
const runner = new AssistantStream ( ) ;
259
259
runner . _run ( ( ) =>
260
260
runner . _runAssistantStream ( threadId , runs , params , {
0 commit comments