(self)
| 776 | return self._find_read_pos() |
| 777 | |
| 778 | def _handle_read(self) -> None: |
| 779 | try: |
| 780 | pos = self._read_to_buffer_loop() |
| 781 | except UnsatisfiableReadError: |
| 782 | raise |
| 783 | except asyncio.CancelledError: |
| 784 | raise |
| 785 | except Exception as e: |
| 786 | gen_log.warning("error on read: %s" % e) |
| 787 | self.close(exc_info=e) |
| 788 | return |
| 789 | if pos is not None: |
| 790 | self._read_from_buffer(pos) |
| 791 | |
| 792 | def _start_read(self) -> Future: |
| 793 | if self._read_future is not None: |
no test coverage detected