Method queueMessage

pkg/web/sse/ssehandler.go:248–269

queueMessage queues an SSEMessage to be written

(msg SSEMessage)

// queueMessage queues an SSEMessage to be written
func (h *SSEHandlerCh) queueMessage(msg SSEMessage) error {
	h.lock.Lock()
	closed := h.closed
	h.lock.Unlock()

	if closed {
		return fmt.Errorf("SSE handler is closed")
	}

	if err := h.Err(); err != nil {
		return err
	}

	select {
	case h.writeCh <- msg:
		return nil
	case <-h.ctx.Done():
		return h.ctx.Err()
	default:
		return fmt.Errorf("write channel is full")
	}
}

// WriteData queues data to be written in SSE format
func (h *SSEHandlerCh) WriteData(data string) error {