Method processStreamChunks

packages/ai-gemini/src/adapters/text.ts:242–647

(
    result: AsyncGenerator<GenerateContentResponse, unknown, unknown>,
    options: TextOptions<GeminiTextProviderOptions>,
    logger: InternalLogger,
  )

  }

  private async *processStreamChunks(
    result: AsyncGenerator<GenerateContentResponse, unknown, unknown>,
    options: TextOptions<GeminiTextProviderOptions>,
    logger: InternalLogger,
  ): AsyncIterable<StreamChunk> {
    const model = options.model
    let accumulatedContent = ''
    let accumulatedThinking = ''
    const toolCallMap = new Map<
      string,
      {
        name: string
        args: string
        index: number
        started: boolean
        thoughtSignature?: string
      }
    >()
    let nextToolIndex = 0

    // AG-UI lifecycle tracking
    const runId = options.runId ?? generateId(this.name)
    const threadId = options.threadId ?? generateId(this.name)
    const messageId = generateId(this.name)
    let stepId: string | null = null
    let reasoningMessageId: string | null = null
    let hasClosedReasoning = false
    let hasEmittedRunStarted = false
    let hasEmittedTextMessageStart = false
    let hasEmittedStepStarted = false

    for await (const chunk of result) {
      logger.provider(`provider=gemini`, { chunk })
      // Emit RUN_STARTED on first chunk
      if (!hasEmittedRunStarted) {
        hasEmittedRunStarted = true
        yield {
          type: EventType.RUN_STARTED,
          runId,
          threadId,
          model,
          timestamp: Date.now(),
          parentRunId: options.parentRunId,
        }
      }

      if (chunk.candidates?.[0]?.content?.parts) {
        const parts = chunk.candidates[0].content.parts

        for (const part of parts) {
          if (part.text) {
            if (part.thought) {
              // Emit STEP_STARTED and REASONING events on first thinking content
              if (!hasEmittedStepStarted) {
                hasEmittedStepStarted = true
                stepId = generateId(this.name)
                reasoningMessageId = generateId(this.name)