(self, event: str, data: dict)
| 77 | done: bool = False |
| 78 | |
| 79 | def push(self, event: str, data: dict) -> None: |
| 80 | self.queue.put({"event": event, "data": data}) |
| 81 | |
| 82 | def write_log(self, stream: str, line: str) -> None: |
| 83 | with self.log_lock: |
no outgoing calls
no test coverage detected