(
self,
pool: "Pool",
*,
max_queries: float,
setup: Optional[Callable[[PoolConnectionProxy], Awaitable[None]]],
max_inactive_time: float,
)
| 118 | '_generation') |
| 119 | |
| 120 | def __init__( |
| 121 | self, |
| 122 | pool: "Pool", |
| 123 | *, |
| 124 | max_queries: float, |
| 125 | setup: Optional[Callable[[PoolConnectionProxy], Awaitable[None]]], |
| 126 | max_inactive_time: float, |
| 127 | ) -> None: |
| 128 | |
| 129 | self._pool = pool |
| 130 | self._con: Optional[connection.Connection] = None |
| 131 | self._proxy: Optional[PoolConnectionProxy] = None |
| 132 | |
| 133 | self._max_queries = max_queries |
| 134 | self._max_inactive_time = max_inactive_time |
| 135 | self._setup = setup |
| 136 | self._inactive_callback: Optional[Callable] = None |
| 137 | self._in_use: Optional[asyncio.Future] = None |
| 138 | self._timeout: Optional[float] = None |
| 139 | self._generation: Optional[int] = None |
| 140 | |
| 141 | def is_connected(self) -> bool: |
| 142 | return self._con is not None and not self._con.is_closed() |
nothing calls this directly
no outgoing calls
no test coverage detected