INNER CODE UNIT · Go

completionsHandler

apache/apisix · t/sse_server_example/main.go:29

func completionsHandler(w http.ResponseWriter, r *http.Request) {
	w.Header().Set("Connection", "close")
	var requestBody struct {
		Stream bool `json:"stream"`
	}

	if r.Body != nil {
		err := json.NewDecoder(r.Body).Decode(&requestBody)
		if err != nil {
			log.Printf("Error parsing request body: %v", err)
			requestBody.Stream = false
		}
		defer r.Body.Close()
	}

	if requestBody.Stream {
		w.Header().Set("Content-Type", "text/event-stream")
		offensive := r.URL.Query().Get("offensive") == "true"

View source record →