(w http.ResponseWriter, eventType string, v interface{})
| 395 | } |
| 396 | |
| 397 | func writeNamedSSEEvent(w http.ResponseWriter, eventType string, v interface{}) error { |
| 398 | data, err := json.Marshal(v) |
| 399 | if err != nil { |
| 400 | return err |
| 401 | } |
| 402 | if _, err := fmt.Fprintf(w, "event: %s\n", eventType); err != nil { |
| 403 | return err |
| 404 | } |
| 405 | _, err = fmt.Fprintf(w, "data: %s\n\n", data) |
| 406 | return err |
| 407 | } |
| 408 | |
| 409 | func writeResponsesAPIStreaming(t testing.TB, w http.ResponseWriter, r *http.Request, resp OpenAIResponse) { |
| 410 | w.Header().Set("Content-Type", "text/event-stream") |
no test coverage detected