| 280 | |
| 281 | |
| 282 | class AfterPubSubConnectionInstantiationEvent: |
| 283 | def __init__( |
| 284 | self, |
| 285 | pubsub_connection, |
| 286 | connection_pool, |
| 287 | client_type: ClientType, |
| 288 | connection_lock: Union[threading.RLock, asyncio.Lock], |
| 289 | ): |
| 290 | self._pubsub_connection = pubsub_connection |
| 291 | self._connection_pool = connection_pool |
| 292 | self._client_type = client_type |
| 293 | self._connection_lock = connection_lock |
| 294 | |
| 295 | @property |
| 296 | def pubsub_connection(self): |
| 297 | return self._pubsub_connection |
| 298 | |
| 299 | @property |
| 300 | def connection_pool(self): |
| 301 | return self._connection_pool |
| 302 | |
| 303 | @property |
| 304 | def client_type(self) -> ClientType: |
| 305 | return self._client_type |
| 306 | |
| 307 | @property |
| 308 | def connection_lock(self) -> Union[threading.RLock, asyncio.Lock]: |
| 309 | return self._connection_lock |
| 310 | |
| 311 | |
| 312 | class AfterAsyncClusterInstantiationEvent: |
no outgoing calls
no test coverage detected