(self, event: h3_events.DataReceived)
| 589 | response.waiter.set_exception(Exception("Headers after trailers received.")) |
| 590 | |
| 591 | def http_data_received(self, event: h3_events.DataReceived) -> None: |
| 592 | assert event.push_id is None |
| 593 | response = self._responses[event.stream_id] |
| 594 | if response.waiter.done(): |
| 595 | return |
| 596 | if response.headers is None: |
| 597 | response.waiter.set_exception(Exception("Data without headers received.")) |
| 598 | elif response.trailers is None: |
| 599 | if response.data is None: |
| 600 | response.data = event.data |
| 601 | else: |
| 602 | response.data = response.data + event.data |
| 603 | if event.stream_ended: |
| 604 | response.waiter.set_result(response) |
| 605 | elif event.data or not event.stream_ended: |
| 606 | response.waiter.set_exception(Exception("Data after trailers received.")) |
| 607 | else: |
| 608 | response.waiter.set_result(response) |
| 609 | |
| 610 | def http_event_received(self, event: h3_events.H3Event) -> None: |
| 611 | if isinstance(event, h3_events.HeadersReceived): |
no test coverage detected