(self)
| 131 | self.subscribers: list[Queue] = [] |
| 132 | |
| 133 | def register(self) -> Queue: |
| 134 | q = Queue(maxsize=CACHED_SIZE + 10) |
| 135 | self.subscribers.append(q) |
| 136 | return q |
| 137 | |
| 138 | def unregister(self, q: Queue) -> None: |
| 139 | self.subscribers.remove(q) |
no test coverage detected