MCPcopy Index your code
hub / github.com/wavetermdev/waveterm / writeEvent

Method writeEvent

pkg/web/sse/ssehandler.go:217–230  ·  view source on GitHub ↗

writeEvent writes an SSE event with optional event type

(eventType, data string)

Source from the content-addressed store, hash-verified

215
216// writeEvent writes an SSE event with optional event type
217func (h *SSEHandlerCh) writeEvent(eventType, data string) error {
218 if !h.isInitialized() {
219 panic("SSEHandlerCh not initialized - call SetupSSE first")
220 }
221 if eventType != "" {
222 if _, err := fmt.Fprintf(h.w, "event: %s\n", eventType); err != nil {
223 return err
224 }
225 }
226 if _, err := fmt.Fprintf(h.w, "data: %s\n\n", data); err != nil {
227 return err
228 }
229 return h.flush()
230}
231
232// flush attempts to flush the response writer
233func (h *SSEHandlerCh) flush() error {

Callers 1

writeMessageMethod · 0.95

Calls 2

isInitializedMethod · 0.95
flushMethod · 0.95

Tested by

no test coverage detected