(self)
| 434 | return self._subs.get(sub_id) |
| 435 | |
| 436 | def start_background_loop(self) -> None: |
| 437 | if self._loop_task is not None and not self._loop_task.done(): |
| 438 | return |
| 439 | self._loop_task = asyncio.create_task(self._periodic_loop()) |
| 440 | self._loop_task.add_done_callback( |
| 441 | lambda t: log.error("Subscription loop failed: %s", t.exception()) |
| 442 | if not t.cancelled() and t.exception() |
| 443 | else None |
| 444 | ) |
| 445 | |
| 446 | async def _periodic_loop(self) -> None: |
| 447 | while True: |
no test coverage detected