(self, n, timeout)
| 116 | 'cursor cannot be created outside of a transaction') |
| 117 | |
| 118 | async def _bind_exec(self, n, timeout): |
| 119 | self._check_ready() |
| 120 | |
| 121 | if self._portal_name: |
| 122 | raise exceptions.InterfaceError( |
| 123 | 'cursor already has an open portal') |
| 124 | |
| 125 | con = self._connection |
| 126 | protocol = con._protocol |
| 127 | |
| 128 | self._portal_name = con._get_unique_id('portal') |
| 129 | buffer, _, self._exhausted = await protocol.bind_execute( |
| 130 | self._state, self._args, self._portal_name, n, True, timeout) |
| 131 | return buffer |
| 132 | |
| 133 | async def _bind(self, timeout): |
| 134 | self._check_ready() |
no test coverage detected