(self)
| 197 | asyncio.gather(self._executor.join(), self._rtt_monitor.join(), return_exceptions=True) # type: ignore[func-returns-value] |
| 198 | |
| 199 | def close(self) -> None: |
| 200 | self.gc_safe_close() |
| 201 | self._rtt_monitor.close() |
| 202 | # Increment the generation and maybe close the socket. If the executor |
| 203 | # thread has the socket checked out, it will be closed when checked in. |
| 204 | self._reset_connection() |
| 205 | |
| 206 | def _reset_connection(self) -> None: |
| 207 | # Clear our pooled connection. |
no test coverage detected