(self, result)
| 492 | self.on_error(result) |
| 493 | |
| 494 | def on_page(self, result): |
| 495 | with self._condition: |
| 496 | if self._state: |
| 497 | self._state.num_pages_received += 1 |
| 498 | self._page_queue.appendleft((result.column_names, result.parsed_rows, None)) |
| 499 | self._stop |= result.continuous_paging_last |
| 500 | self._condition.notify() |
| 501 | |
| 502 | if result.continuous_paging_last: |
| 503 | self.released = True |
| 504 | |
| 505 | def on_error(self, error): |
| 506 | if isinstance(error, ErrorMessage): |