Throw StreamResetError on stream reset

Author: Lukasa

hyper/http20/stream.py

@@ -16,9 +16,9 @@
 from ..common.headers import HTTPHeaderMap
 from ..packages.hyperframe.frame import (
     FRAME_MAX_LEN, FRAMES, HeadersFrame, DataFrame, PushPromiseFrame,
-    WindowUpdateFrame, ContinuationFrame, BlockedFrame
+    WindowUpdateFrame, ContinuationFrame, BlockedFrame, RstStreamFrame
 )
-from .exceptions import ProtocolError
+from .exceptions import ProtocolError, StreamResetError
 from .util import h2_safe_headers
 import collections
 import logging
@@ -233,6 +233,9 @@ def receive_frame(self, frame):
                 w = WindowUpdateFrame(self.stream_id)
                 w.window_increment = increment
                 self._data_cb(w, True)
+        elif frame.type == RstStreamFrame.type:
+            self.close(0)
+            raise StreamResetError("Stream forcefully closed.")
         elif frame.type in FRAMES:
             # This frame isn't valid at this point.
             raise ValueError("Unexpected frame %s." % frame)