diff --git a/packages/typescript/ai-client/src/connection-adapters.ts b/packages/typescript/ai-client/src/connection-adapters.ts index 91d63a146..cb29b5a9b 100644 --- a/packages/typescript/ai-client/src/connection-adapters.ts +++ b/packages/typescript/ai-client/src/connection-adapters.ts @@ -265,14 +265,14 @@ export function fetchServerSentEvents( url: string | (() => string), options: | FetchConnectionOptions - | (() => FetchConnectionOptions | Promise) = {}, + | ((messages:Array | Array) => FetchConnectionOptions | Promise) = {}, ): ConnectConnectionAdapter { return { async *connect(messages, data, abortSignal) { // Resolve URL and options if they are functions const resolvedUrl = typeof url === 'function' ? url() : url const resolvedOptions = - typeof options === 'function' ? await options() : options + typeof options === 'function' ? await options(messages) : options const requestHeaders: Record = { 'Content-Type': 'application/json',