(self, timeout: float, message: str)
| 79 | self._registered_listeners.append((emitter, event, listener)) |
| 80 | |
| 81 | def reject_on_timeout(self, timeout: float, message: str) -> None: |
| 82 | if timeout == 0: |
| 83 | return |
| 84 | |
| 85 | async def reject() -> None: |
| 86 | await asyncio.sleep(timeout / 1000) |
| 87 | self._reject(TimeoutError(message)) |
| 88 | |
| 89 | self._pending_tasks.append(self._loop.create_task(reject())) |
| 90 | |
| 91 | def _cleanup(self) -> None: |
| 92 | for task in self._pending_tasks: |
no test coverage detected