Run a "hello" command and return the RTT.
(self)
| 491 | await self._pool.reset() |
| 492 | |
| 493 | async def _ping(self) -> float: |
| 494 | """Run a "hello" command and return the RTT.""" |
| 495 | async with self._pool.checkout() as conn: |
| 496 | if self._executor._stopped: |
| 497 | raise Exception("_RttMonitor closed") |
| 498 | start = time.monotonic() |
| 499 | await conn.hello() |
| 500 | return _monotonic_duration(start) |
| 501 | |
| 502 | |
| 503 | # Close monitors to cancel any in progress streaming checks before joining |
no test coverage detected