(self)
| 155 | conn._reader.set_exception(EOFError("EOF")) |
| 156 | |
| 157 | async def _close(self) -> None: |
| 158 | if self._pool: # pragma: nobranch |
| 159 | self._pool.close() |
| 160 | await self._pool.wait_closed() |
| 161 | self.log.debug("Closed connection %s with params: %s", self._connection, self._template) |
| 162 | self._pool = None |
| 163 | |
| 164 | async def close(self) -> None: |
| 165 | await self._close() |