Method streamOpenAICompatible

api/client.go:680–867

(
	ctx context.Context,
	url string,
	headers map[string]string,
	body []byte,
)

		MaxTokens: opts.MaxTokens, RequiredTool: opts.RequiredTool, DisableThinking: opts.DisableThinking,
		Temperature: opts.Temperature,
	}))
}

func (c *OpenAICompatibleClient) StreamChat(
	ctx context.Context,
	systemPrompt string,
	messages []map[string]any,
	tools []map[string]any,
	options *LLMRequestOptions,
) <-chan EventResult {
	url := c.chatCompletionsURL()
	headers := c.buildHeaders()
	openaiMessages := c.buildMessages(systemPrompt, messages)

	bodyMap := map[string]any{
		"model":          c.Model,
		"messages":       openaiMessages,
		"stream":         true,
		"stream_options": map[string]any{"include_usage": true},
	}
	if options != nil && options.MaxTokens > 0 {
		bodyMap["max_completion_tokens"] = options.MaxTokens
	}
	if options != nil && options.Temperature != nil {
		bodyMap["temperature"] = *options.Temperature
	}

	if len(tools) > 0 {
		bodyMap["tools"] = AnthropicToolsToOpenAI(tools)
	}
	if options != nil && options.RequiredTool != "" {
		bodyMap["tool_choice"] = map[string]any{
			"type": "function", "function": map[string]any{"name": options.RequiredTool},
		}
	}
	if options != nil && options.DisableThinking && supportsThinkingControl(c.Model) {
		bodyMap["thinking"] = map[string]any{"type": "disabled"}
	}

	bodyBytes, err := json.Marshal(bodyMap)
	if err != nil {
		return singleErrorEvent(err)
	}

	return RetryWithBackoff(ctx, c.streamOpenAICompatible, func() (RequestParts, error) {
		return RequestParts{
			URL:     url,
			Headers: headers,
			Body:    bodyBytes,
		}, nil
	}, c.RetryConfig)
}

func (c *OpenAICompatibleClient) streamOpenAICompatible(
	ctx context.Context,
	url string,
	headers map[string]string,
	body []byte,