(self, event: ResponseReceived)
| 413 | stream.receive_data(event.data, event.flow_controlled_length) |
| 414 | |
| 415 | def response_received(self, event: ResponseReceived) -> None: |
| 416 | try: |
| 417 | stream = self.streams[event.stream_id] |
| 418 | except KeyError: |
| 419 | pass # We ignore server-initiated events |
| 420 | else: |
| 421 | stream.receive_headers(cast("list[tuple[str, str]]", event.headers)) |
| 422 | |
| 423 | def settings_acknowledged(self, event: SettingsAcknowledged) -> None: |
| 424 | self.metadata["settings_acknowledged"] = True |
no test coverage detected