(ch <-chan Event)
| 19 | |
| 20 | func collect(ch <-chan Event) []Event { |
| 21 | var evs []Event |
| 22 | for e := range ch { |
| 23 | evs = append(evs, e) |
| 24 | } |
| 25 | return evs |
| 26 | } |
| 27 | |
| 28 | // sseOK writes a Responses stream: each event as `event:`+`data:` the way |
| 29 | // OpenAI and vLLM emit it, closed by response.completed carrying the usage. |
| 30 | func sseOK(w http.ResponseWriter, events []string) { |
no outgoing calls
no test coverage detected