(self, action: str, timeout_seconds: float | None)
| 41 | await self._submit("cleanup", self._cleanup_timeout_seconds) |
| 42 | |
| 43 | async def _submit(self, action: str, timeout_seconds: float | None) -> None: |
| 44 | loop = asyncio.get_running_loop() |
| 45 | future: asyncio.Future[None] = loop.create_future() |
| 46 | await self._queue.put( |
| 47 | _ServerCommand(action=action, timeout_seconds=timeout_seconds, future=future) |
| 48 | ) |
| 49 | await future |
| 50 | |
| 51 | async def _run(self) -> None: |
| 52 | while True: |
no test coverage detected