(self)
| 524 | self.on_response() |
| 525 | |
| 526 | async def receive(self) -> ASGIReceiveEvent: |
| 527 | if self.waiting_for_100_continue and not self.transport.is_closing(): |
| 528 | headers: list[tuple[str, str]] = [] |
| 529 | event = h11.InformationalResponse(status_code=100, headers=headers, reason="Continue") |
| 530 | output = self.conn.send(event=event) |
| 531 | self.transport.write(output) |
| 532 | self.waiting_for_100_continue = False |
| 533 | |
| 534 | if not self.disconnected and not self.response_complete: |
| 535 | self.flow.resume_reading() |
| 536 | await self.message_event.wait() |
| 537 | self.message_event.clear() |
| 538 | |
| 539 | if self.disconnected or self.response_complete: |
| 540 | return {"type": "http.disconnect"} |
| 541 | |
| 542 | message: HTTPRequestEvent = {"type": "http.request", "body": bytes(self.body), "more_body": self.more_body} |
| 543 | self.body = bytearray() |
| 544 | return message |
nothing calls this directly
no test coverage detected