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