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