Function errorStream

packages/ai/tests/stream-to-response.test.ts:230–240

()

  it('should handle stream errors and send error chunk', async () => {
    async function* errorStream(): AsyncGenerator<StreamChunk> {
      yield {
        type: EventType.TEXT_MESSAGE_CONTENT,
        messageId: 'msg-1',
        model: 'test',
        timestamp: Date.now(),
        delta: 'Test',
        content: 'Test',
      }
      throw new Error('Stream error')
    }

    const sseStream = toServerSentEventsStream(errorStream())
    const output = await readStream(sseStream)