SetEventBus attaches an event bus for real-time SSE streaming.
(bus events.EventBus)
| 838 | |
| 839 | // SetEventBus attaches an event bus for real-time SSE streaming. |
| 840 | func (s *Server) SetEventBus(bus events.EventBus) { |
| 841 | s.events = bus |
| 842 | } |
| 843 | |
| 844 | // SetWatchEventsBus attaches the watch/nudge notification bus consumed by |
| 845 | // GET /api/v1/events/stream (TASK-2533). Nil-checked by every producer and |
no outgoing calls