(self, n, timeout)
| 147 | return buffer |
| 148 | |
| 149 | async def _exec(self, n, timeout): |
| 150 | self._check_ready() |
| 151 | |
| 152 | if not self._portal_name: |
| 153 | raise exceptions.InterfaceError( |
| 154 | 'cursor does not have an open portal') |
| 155 | |
| 156 | protocol = self._connection._protocol |
| 157 | buffer, _, self._exhausted = await protocol.execute( |
| 158 | self._state, self._portal_name, n, True, timeout) |
| 159 | return buffer |
| 160 | |
| 161 | async def _close_portal(self, timeout): |
| 162 | self._check_ready() |
no test coverage detected