(self, body: bytes)
| 310 | self.tasks.add(task) |
| 311 | |
| 312 | def on_body(self, body: bytes) -> None: |
| 313 | if (self.parser.should_upgrade() and self._should_upgrade()) or self.cycle.response_complete: |
| 314 | return |
| 315 | self.cycle.body += body |
| 316 | if len(self.cycle.body) > HIGH_WATER_LIMIT: |
| 317 | self.flow.pause_reading() |
| 318 | self.cycle.message_event.set() |
| 319 | |
| 320 | def on_message_complete(self) -> None: |
| 321 | if (self.parser.should_upgrade() and self._should_upgrade()) or self.cycle.response_complete: |
nothing calls this directly
no test coverage detected