Helper for :meth:`connection_or_acquire`.
(self, pool=True)
| 1069 | broker_connection = connection |
| 1070 | |
| 1071 | def _acquire_connection(self, pool=True): |
| 1072 | """Helper for :meth:`connection_or_acquire`.""" |
| 1073 | if pool: |
| 1074 | return self.pool.acquire(block=True) |
| 1075 | return self.connection_for_write() |
| 1076 | |
| 1077 | def connection_or_acquire(self, connection=None, pool=True, *_, **__): |
| 1078 | """Context used to acquire a connection from the pool. |
nothing calls this directly
no test coverage detected