diff --git a/libs/sdk-js/src/react/stream.tsx b/libs/sdk-js/src/react/stream.tsx index 8ac73ca9e..68af6ffa8 100644 --- a/libs/sdk-js/src/react/stream.tsx +++ b/libs/sdk-js/src/react/stream.tsx @@ -621,7 +621,11 @@ export interface UseStream< /** * Join an active stream. */ - joinStream: (runId: string) => Promise; + joinStream: ( + runId: string, + lastEventId?: string, + options?: { streamMode?: StreamMode | StreamMode[] }, + ) => Promise; } type ConfigWithConfigurable> = @@ -962,13 +966,18 @@ 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 {