

def _receive_rst_stream_frame(self, frame):
    '\n        Receive a RST_STREAM frame on the connection.\n        '
    events = self.state_machine.process_input(ConnectionInputs.RECV_RST_STREAM)
    try:
        stream = self._get_stream_by_id(frame.stream_id)
    except NoSuchStreamError:
        stream_frames = []
        stream_events = []
    else:
        (stream_frames, stream_events) = stream.stream_reset(frame)
    return (stream_frames, (events + stream_events))

dataset/ETHPy150Open python-hyper/hyper-h2/h2/connection.py H2Connection._receive_rst_stream_frame/original