(self, size: int = 10000)
| 11 | |
| 12 | class EventStore: |
| 13 | def __init__(self, size: int = 10000) -> None: |
| 14 | self.data: collections.deque[LogEntry] = collections.deque(maxlen=size) |
| 15 | self.sig_add = signals.SyncSignal(lambda entry: None) |
| 16 | self.sig_refresh = signals.SyncSignal(lambda: None) |
| 17 | |
| 18 | self.logger = CallbackLogger(self._add_log) |
| 19 | self.logger.install() |
| 20 | |
| 21 | def done(self): |
| 22 | self.logger.uninstall() |
no test coverage detected