(self, log_entry: dict)
| 139 | self.subscribers.remove(q) |
| 140 | |
| 141 | def publish(self, log_entry: dict) -> None: |
| 142 | self.log_cache.append(log_entry) |
| 143 | for q in self.subscribers: |
| 144 | try: |
| 145 | q.put_nowait(log_entry) |
| 146 | except asyncio.QueueFull: |
| 147 | pass |
| 148 | |
| 149 | |
| 150 | class LogQueueHandler(logging.Handler): |