Method writerLoop

pkg/web/sse/ssehandler.go:134–166

writerLoop handles all writes and keepalives in a single goroutine

()

// writerLoop handles all writes and keepalives in a single goroutine
func (h *SSEHandlerCh) writerLoop() {
	defer h.wg.Done()
	defer h.runOnCloseHandlers()

	keepaliveTicker := time.NewTicker(SSEKeepaliveInterval)
	defer keepaliveTicker.Stop()

	for {
		select {
		case msg, ok := <-h.writeCh:
			if !ok {
				// Channel closed, send [DONE] and exit
				h.writeDirectly("[DONE]", SSEMsgData)
				return
			}

			if err := h.writeMessage(msg); err != nil {
				h.setError(err)
				return
			}

		case <-keepaliveTicker.C:
			if err := h.writeDirectly("keepalive", SSEMsgComment); err != nil {
				h.setError(err)
				return
			}

		case <-h.ctx.Done():
			h.setError(h.ctx.Err())
			return
		}
	}
}

// writeMessage writes a message to the SSE stream
func (h *SSEHandlerCh) writeMessage(msg SSEMessage) error {