Function xhrHttpStream

packages/ai-client/src/connection-adapters.ts:895–923

(
  url: string | (() => string),
  options: XhrConnectionOptionsResolver = {},
)

 * Create an XMLHttpRequest-backed newline-delimited JSON stream adapter.
 */
export function xhrHttpStream(
  url: string | (() => string),
  options: XhrConnectionOptionsResolver = {},
): ConnectConnectionAdapter {
  return {
    async *connect(messages, data, abortSignal, runContext) {
      const resolvedUrl = typeof url === 'function' ? url() : url
      const resolvedOptions = await resolveXhrConnectionOptions(options)
      const signal = abortSignal || resolvedOptions.signal
      const request = createConfiguredXhrRequest(
        resolvedUrl,
        resolvedOptions,
        messages,
        data,
        runContext,
      )
      const lines = readXhrLines(request.xhr, signal)
      if (signal?.aborted) {
        await lines.next()
        return
      }
      request.xhr.send(request.body)

      for await (const line of lines) {
        yield JSON.parse(line) as StreamChunk
      }
    },
  }
}

/**
 * Create a direct stream connection adapter (for server functions or direct streams)