Function readStream

packages/ai/tests/stream-to-response.test.ts:19–35

(stream: ReadableStream<Uint8Array>)

// Helper to read ReadableStream
async function readStream(stream: ReadableStream<Uint8Array>): Promise<string> {
  const reader = stream.getReader()
  const decoder = new TextDecoder()
  let result = ''

  try {
    while (true) {
      const { done, value } = await reader.read()
      if (done) break
      result += decoder.decode(value, { stream: true })
    }
  } finally {
    reader.releaseLock()
  }

  return result
}

describe('toServerSentEventsStream', () => {
  it('should convert chunks to SSE format', async () => {