diff --git a/libs/sdk-js/src/react/stream.tsx b/libs/sdk-js/src/react/stream.tsx index e2610974d..6d3f96b77 100644 --- a/libs/sdk-js/src/react/stream.tsx +++ b/libs/sdk-js/src/react/stream.tsx @@ -874,16 +874,16 @@ export function useStream< return { ...values, [messagesKey!]: messages }; }); } - - // TODO: stream created checkpoints to avoid an unnecessary network request - const result = await run.onFinish(); - - setStreamValues(null); - if (streamError != null) throw streamError; - - const lastHead = result.at(0); - if (lastHead) onFinish?.(lastHead); } + + // TODO: stream created checkpoints to avoid an unnecessary network request + const result = await run.onFinish(); + + setStreamValues(null); + if (streamError != null) throw streamError; + + const lastHead = result.at(0); + if (lastHead) onFinish?.(lastHead); } catch (error) { if ( !( @@ -994,6 +994,7 @@ export function useStream< checkpoint, streamMode, streamSubgraphs: submitOptions?.streamSubgraphs, + streamResumable: !!options.joinOnMount, onRunCreated(params) { if (options.joinOnMount) { rejoinKey = `lg:rejoin:${params.thread_id ?? "temporary"}`;