(self)
| 96 | return self._session |
| 97 | |
| 98 | async def ensure_initialized(self): |
| 99 | session = await self.get_session() |
| 100 | if self._initialized and self._initialize_result is not None: |
| 101 | return session, self._initialize_result |
| 102 | |
| 103 | async with self._initialize_lock: |
| 104 | if not self._initialized or self._initialize_result is None: |
| 105 | initialize_result = await session.initialize() |
| 106 | self._initialize_result = initialize_result |
| 107 | self._initialized = True |
| 108 | else: |
| 109 | initialize_result = self._initialize_result |
| 110 | |
| 111 | return session, initialize_result |
| 112 | |
| 113 | async def reconnect(self): |
| 114 | async with self._lock: |
no test coverage detected