(self, error)
| 503 | self.released = True |
| 504 | |
| 505 | def on_error(self, error): |
| 506 | if isinstance(error, ErrorMessage): |
| 507 | error = error.to_exception() |
| 508 | |
| 509 | log.debug("Got error %s for session %s", error, self.stream_id) |
| 510 | |
| 511 | with self._condition: |
| 512 | self._page_queue.appendleft((None, None, error)) |
| 513 | self._stop = True |
| 514 | self._condition.notify() |
| 515 | |
| 516 | self.released = True |
| 517 | |
| 518 | def results(self): |
| 519 | try: |
no test coverage detected