Function InjectStream

internal/toolinjection/inject_stream.go:28–34

--------------------------------------------------------------------------- OpenAI Chat Completions streaming injection Chunks are raw JSON; the handler wraps them with "data: %s\n\n". --------------------------------------------------------------------------- InjectStream dispatches to the format-s

(dataChan <-chan []byte, rule *config.ToolCallInjectionRule, modelName string, format string)

// InjectStream dispatches to the format-specific streaming injection wrapper.
func InjectStream(dataChan <-chan []byte, rule *config.ToolCallInjectionRule, modelName string, format string) <-chan []byte {
	f := GetFormat(format)
	if f == nil {
		return dataChan
	}
	return f.InjectStream(dataChan, rule, modelName)
}

// InjectOpenAIStream wraps a data channel to inject tool_call chunks into a
// real OpenAI streaming response.