(self, event: StreamReset)
| 440 | stream.close(StreamCloseReason.ENDED, from_protocol=True) |
| 441 | |
| 442 | def stream_reset(self, event: StreamReset) -> None: |
| 443 | try: |
| 444 | stream = self.pop_stream(event.stream_id) |
| 445 | except KeyError: |
| 446 | pass # We ignore server-initiated events |
| 447 | else: |
| 448 | stream.close(StreamCloseReason.RESET, from_protocol=True) |
| 449 | |
| 450 | def window_updated(self, event: WindowUpdated) -> None: |
| 451 | if event.stream_id != 0: |
no test coverage detected