(self, size: int)
| 813 | return self._read_future |
| 814 | |
| 815 | def _finish_read(self, size: int) -> None: |
| 816 | if self._user_read_buffer: |
| 817 | self._read_buffer = self._after_user_read_buffer or bytearray() |
| 818 | self._after_user_read_buffer = None |
| 819 | self._read_buffer_pos = 0 |
| 820 | self._read_buffer_size = len(self._read_buffer) |
| 821 | self._user_read_buffer = False |
| 822 | result = size # type: Union[int, bytes] |
| 823 | else: |
| 824 | result = self._consume(size) |
| 825 | if self._read_future is not None: |
| 826 | future = self._read_future |
| 827 | self._read_future = None |
| 828 | future_set_result_unless_cancelled(future, result) |
| 829 | self._maybe_add_error_listener() |
| 830 | |
| 831 | def _try_inline_read(self) -> None: |
| 832 | """Attempt to complete the current read operation from buffered data. |
no test coverage detected