Function structuredOutputStream

packages/openai-base/src/adapters/responses-text.ts:282–646

* Stream structured output via the Responses API: single request with * `text.format: json_schema` + `stream: true`. Consumes Responses-API * events (`response.output_text.delta`, `response.reasoning_text.delta`, * `response.reasoning_summary_text.delta`, `response.refusal.delta`, * `res

(
    options: StructuredOutputOptions<TProviderOptions>,
  )

   * CUSTOM event's `value.reasoning`.
   */
  async *structuredOutputStream(
    options: StructuredOutputOptions<TProviderOptions>,
  ): AsyncIterable<StreamChunk> {
    const { chatOptions, outputSchema } = options
    const requestParams = this.mapOptionsToRequest(chatOptions)

    const jsonSchema = this.makeStructuredOutputCompatible(
      outputSchema,
      outputSchema.required,
    )

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

    let accumulatedContent = ''
    let accumulatedReasoning = ''
    let hasEmittedTextMessageStart = false
    let reasoningMessageId: string | undefined
    let stepId: string | undefined
    let hasClosedReasoning = false
    let model: string = chatOptions.model
    let usage: OpenAI.Responses.Response['usage'] | undefined

    const closeReasoning = function* (this: {
      name: string
    }): Generator<StreamChunk> {
      if (reasoningMessageId && !hasClosedReasoning) {
        hasClosedReasoning = true
        yield {
          type: EventType.REASONING_MESSAGE_END,
          messageId: reasoningMessageId,
          model,
          timestamp,
        }
        yield {
          type: EventType.REASONING_END,
          messageId: reasoningMessageId,
          model,
          timestamp,
        }
        if (stepId) {
          yield {
            type: EventType.STEP_FINISHED,
            stepName: stepId,
            stepId,
            model,
            timestamp,
            content: accumulatedReasoning,
          }
        }
      }
    }.bind(this)