(self, connection_pool, response_callbacks, transaction, shard_hint)
| 225 | _is_async_client: Literal[True] = True |
| 226 | |
| 227 | def __init__(self, connection_pool, response_callbacks, transaction, shard_hint): |
| 228 | # ``AsyncioPipeline.__init__`` is next in MRO and won't chain to |
| 229 | # the sync ``Pipeline.__init__``, so we set up callbacks here. |
| 230 | super().__init__( |
| 231 | connection_pool, dict(response_callbacks), transaction, shard_hint |
| 232 | ) |
| 233 | self._init_module_callbacks() |
| 234 | self._register_module_callbacks() |
| 235 | |
| 236 | @property |
| 237 | def client(self): |
nothing calls this directly
no test coverage detected