Method chatStream

packages/ai-mistral/src/adapters/text.ts:185–231

(
    options: TextOptions<TProviderOptions>,
  )

  }

  async *chatStream(
    options: TextOptions<TProviderOptions>,
  ): AsyncIterable<StreamChunk> {
    const requestParams = this.mapTextOptionsToMistral(options)
    const timestamp = Date.now()

    const aguiState = {
      runId: options.runId ?? generateId(this.name),
      threadId: options.threadId ?? generateId(this.name),
      messageId: generateId(this.name),
      timestamp,
      hasEmittedRunStarted: false,
    }

    try {
      const stream = this.fetchRawMistralStream(requestParams, this.rawConfig)
      yield* this.processMistralStreamChunks(stream, options, aguiState)
    } catch (error: unknown) {
      const err = error as Error & { code?: string }

      if (!aguiState.hasEmittedRunStarted) {
        aguiState.hasEmittedRunStarted = true
        yield asChunk({
          type: 'RUN_STARTED',
          runId: aguiState.runId,
          threadId: aguiState.threadId,
          model: options.model,
          timestamp,
        })
      }

      yield asChunk({
        type: 'RUN_ERROR',
        runId: aguiState.runId,
        model: options.model,
        timestamp,
        message: err.message || 'Unknown error',
        code: err.code,
        error: {
          message: err.message || 'Unknown error',
          code: err.code,
        },
      })

      throw err
    }
  }

  /**
   * Generate structured output using Mistral's JSON Schema response format.