Parse Content-Length delimited body.
(self)
| 680 | self._on_message_complete() |
| 681 | |
| 682 | def _parse_body(self): |
| 683 | """Parse Content-Length delimited body.""" |
| 684 | if not self._buffer or self._body_remaining <= 0: |
| 685 | return False |
| 686 | |
| 687 | chunk_size = min(len(self._buffer), self._body_remaining) |
| 688 | chunk = bytes(self._buffer[:chunk_size]) |
| 689 | del self._buffer[:chunk_size] |
| 690 | self._body_remaining -= chunk_size |
| 691 | |
| 692 | if self._on_body: |
| 693 | self._on_body(chunk) |
| 694 | |
| 695 | if self._body_remaining <= 0: |
| 696 | self._state = 'complete' |
| 697 | self.is_complete = True |
| 698 | if self._on_message_complete: |
| 699 | self._on_message_complete() |
| 700 | |
| 701 | return True |
| 702 | |
| 703 | def _parse_chunked_body(self): |
| 704 | """Parse chunked transfer encoding.""" |
no test coverage detected