Callback: request headers are complete.
(self)
| 532 | self._callback_parser = parser_class(**parser_kwargs) |
| 533 | |
| 534 | def _on_headers_complete(self): |
| 535 | """Callback: request headers are complete.""" |
| 536 | # Build request from parser state |
| 537 | self._current_request = CallbackRequest.from_parser( |
| 538 | self._callback_parser, is_ssl=self._is_ssl |
| 539 | ) |
| 540 | |
| 541 | # Create body receiver for this request |
| 542 | self._body_receiver = BodyReceiver(self._current_request, self) |
| 543 | |
| 544 | # Signal that request is ready for processing |
| 545 | if self._request_ready: |
| 546 | self._request_ready.set() |
| 547 | |
| 548 | # Return True for HEAD to skip body parsing |
| 549 | return self._callback_parser.method == b'HEAD' |
| 550 | |
| 551 | def _on_body(self, chunk): |
| 552 | """Callback: received body data chunk.""" |
no test coverage detected