| 462 | return self.initialize().__await__() |
| 463 | |
| 464 | async def initialize(self: _RedisT) -> _RedisT: |
| 465 | if self.single_connection_client: |
| 466 | async with self._single_conn_lock: |
| 467 | if self.connection is None: |
| 468 | self.connection = await self.connection_pool.get_connection() |
| 469 | |
| 470 | self._event_dispatcher.dispatch( |
| 471 | AfterSingleConnectionInstantiationEvent( |
| 472 | self.connection, ClientType.ASYNC, self._single_conn_lock |
| 473 | ) |
| 474 | ) |
| 475 | return self |
| 476 | |
| 477 | def set_response_callback(self, command: str, callback: ResponseCallbackT): |
| 478 | """Set a custom Response Callback""" |