(self, event: DataReceived)
| 405 | ) |
| 406 | |
| 407 | def data_received(self, event: DataReceived) -> None: |
| 408 | try: |
| 409 | stream = self.streams[event.stream_id] |
| 410 | except KeyError: |
| 411 | pass # We ignore server-initiated events |
| 412 | else: |
| 413 | stream.receive_data(event.data, event.flow_controlled_length) |
| 414 | |
| 415 | def response_received(self, event: ResponseReceived) -> None: |
| 416 | try: |
no test coverage detected