diff --git a/h2/events.py b/h2/events.py index d52b8ff38..b556bc97b 100644 --- a/h2/events.py +++ b/h2/events.py @@ -146,9 +146,20 @@ class _HeadersSent(object): pass -class _ResponseHeadersSent(_HeadersSent): +class _ResponseSent(_HeadersSent): """ - The _ResponseHeadersSent event is fired whenever response headers are sent + The _ResponseSent event is fired whenever response headers are sent + on a stream. + + This is an internal event, used to determine validation steps on + outgoing header blocks. + """ + pass + + +class _RequestSent(_HeadersSent): + """ + The _RequestSent event is fired whenever request headers are sent on a stream. This is an internal event, used to determine validation steps on diff --git a/h2/stream.py b/h2/stream.py index ac8b05e33..eae7efcc0 100644 --- a/h2/stream.py +++ b/h2/stream.py @@ -19,7 +19,7 @@ RequestReceived, ResponseReceived, DataReceived, WindowUpdated, StreamEnded, PushedStreamReceived, StreamReset, TrailersReceived, InformationalResponseReceived, AlternativeServiceAvailable, - _HeadersSent, _ResponseHeadersSent, _TrailersSent + _HeadersSent, _ResponseSent, _RequestSent, _TrailersSent ) from .exceptions import ( ProtocolError, StreamClosedError, InvalidBodyLengthError @@ -133,7 +133,7 @@ def request_sent(self, previous_state): """ self.client = True self.headers_sent = True - event = _HeadersSent() + event = _RequestSent() return [event] @@ -146,7 +146,7 @@ def response_sent(self, previous_state): if self.client is True or self.client is None: raise ProtocolError("Client cannot send responses.") self.headers_sent = True - event = _ResponseHeadersSent() + event = _ResponseSent() else: assert not self.trailers_sent self.trailers_sent = True @@ -1041,7 +1041,7 @@ def _build_hdr_validation_flags(self, events): events[0], (_TrailersSent, TrailersReceived) ) is_response_header = isinstance( - events[0], (_ResponseHeadersSent, ResponseReceived) + events[0], (_ResponseSent, ResponseReceived) ) except IndexError: # Some state changes don't emit an internal event (for example,