(self)
| 455 | self._lock = _async_create_lock() |
| 456 | |
| 457 | async def close(self) -> None: |
| 458 | self.gc_safe_close() |
| 459 | # Increment the generation and maybe close the socket. If the executor |
| 460 | # thread has the socket checked out, it will be closed when checked in. |
| 461 | await self._pool.reset() |
| 462 | |
| 463 | async def add_sample(self, sample: float) -> None: |
| 464 | """Add a RTT sample.""" |
no test coverage detected