(self, timeout)
| 159 | return buffer |
| 160 | |
| 161 | async def _close_portal(self, timeout): |
| 162 | self._check_ready() |
| 163 | |
| 164 | if not self._portal_name: |
| 165 | raise exceptions.InterfaceError( |
| 166 | 'cursor does not have an open portal') |
| 167 | |
| 168 | protocol = self._connection._protocol |
| 169 | await protocol.close_portal(self._portal_name, timeout) |
| 170 | self._portal_name = None |
| 171 | |
| 172 | def __repr__(self): |
| 173 | attrs = [] |