diff --git a/libs/sdk-js/src/react/stream.tsx b/libs/sdk-js/src/react/stream.tsx index 6db58a587..53c8366c9 100644 --- a/libs/sdk-js/src/react/stream.tsx +++ b/libs/sdk-js/src/react/stream.tsx @@ -616,7 +616,7 @@ export interface UseStream< /** * Join an active stream. */ - joinStream: (runId: string) => Promise; + joinStream: (runId: string, lastEventId?: string, options?: { streamMode?: StreamMode | StreamMode[] }) => Promise; } type ConfigWithConfigurable> = @@ -951,13 +951,14 @@ export function useStream< } } - const joinStream = async (runId: string, lastEventId?: string) => { + const joinStream = async (runId: string, lastEventId?: string, options?: { streamMode?: StreamMode | StreamMode[]; }) => { lastEventId ??= "-1"; if (!threadId) return; await consumeStream(async (signal: AbortSignal) => { const stream = client.runs.joinStream(threadId, runId, { signal, lastEventId, + streamMode: options?.streamMode, }) as AsyncGenerator; return {