(self, data: bytes, flow_controlled_length: int)
| 335 | self.send_data() |
| 336 | |
| 337 | def receive_data(self, data: bytes, flow_controlled_length: int) -> None: |
| 338 | self._response["body"].write(data) |
| 339 | self._response["flow_controlled_size"] += flow_controlled_length |
| 340 | |
| 341 | # We check maxsize here in case the Content-Length header was not received |
| 342 | if ( |
| 343 | self._download_maxsize |
| 344 | and self._response["flow_controlled_size"] > self._download_maxsize |
| 345 | ): |
| 346 | self.reset_stream(StreamCloseReason.MAXSIZE_EXCEEDED_ACTUAL) |
| 347 | return |
| 348 | |
| 349 | if self._log_warnsize: |
| 350 | self.metadata["reached_warnsize"] = True |
| 351 | warning_msg = get_warnsize_msg( |
| 352 | self._response["flow_controlled_size"], |
| 353 | self._download_warnsize, |
| 354 | self._request, |
| 355 | expected=False, |
| 356 | ) |
| 357 | logger.warning(warning_msg) |
| 358 | |
| 359 | # Acknowledge the data received |
| 360 | self._protocol.conn.acknowledge_received_data( |
| 361 | self._response["flow_controlled_size"], self.stream_id |
| 362 | ) |
| 363 | |
| 364 | def receive_headers(self, headers: list[tuple[str, str]]) -> None: |
| 365 | for name, value in headers: |
no test coverage detected