(self)
| 27 | """In-process fan-out message bus for SSE subscribers.""" |
| 28 | |
| 29 | def __init__(self) -> None: |
| 30 | self._lock = threading.Lock() |
| 31 | self._subscribers: list[queue.Queue] = [] |
| 32 | |
| 33 | def subscribe(self) -> queue.Queue: |
| 34 | """Register a new subscriber and return its dedicated queue.""" |
nothing calls this directly
no outgoing calls
no test coverage detected