@@ -30,7 +30,7 @@ class FrameBuffer:
30
30
"""
31
31
32
32
def __init__ (self , server : bool = False ) -> None :
33
- self .data = bytearray ()
33
+ self ._data = bytearray ()
34
34
self .max_frame_size = 0
35
35
self ._preamble = b"PRI * HTTP/2.0\r \n \r \n SM\r \n \r \n " if server else b""
36
36
self ._preamble_len = len (self ._preamble )
@@ -54,7 +54,7 @@ def add_data(self, data: bytes) -> None:
54
54
self ._preamble_len -= of_which_preamble
55
55
self ._preamble = self ._preamble [of_which_preamble :]
56
56
57
- self .data += data
57
+ self ._data += data
58
58
59
59
def _validate_frame_length (self , length : int ) -> None :
60
60
"""
@@ -119,26 +119,26 @@ def __iter__(self) -> FrameBuffer:
119
119
def __next__ (self ) -> Frame :
120
120
# First, check that we have enough data to successfully parse the
121
121
# next frame header. If not, bail. Otherwise, parse it.
122
- if len (self .data ) < 9 :
122
+ if len (self ._data ) < 9 :
123
123
raise StopIteration
124
124
125
125
try :
126
- f , length = Frame .parse_frame_header (memoryview (self .data [:9 ]))
126
+ f , length = Frame .parse_frame_header (memoryview (self ._data [:9 ]))
127
127
except (InvalidDataError , InvalidFrameError ) as err : # pragma: no cover
128
128
msg = f"Received frame with invalid header: { err !s} "
129
129
raise ProtocolError (msg ) from err
130
130
131
131
# Next, check that we have enough length to parse the frame body. If
132
132
# not, bail, leaving the frame header data in the buffer for next time.
133
- if len (self .data ) < length + 9 :
133
+ if len (self ._data ) < length + 9 :
134
134
raise StopIteration
135
135
136
136
# Confirm the frame has an appropriate length.
137
137
self ._validate_frame_length (length )
138
138
139
139
# Try to parse the frame body
140
140
try :
141
- f .parse_body (memoryview (self .data [9 :9 + length ]))
141
+ f .parse_body (memoryview (self ._data [9 :9 + length ]))
142
142
except InvalidDataError as err :
143
143
msg = "Received frame with non-compliant data"
144
144
raise ProtocolError (msg ) from err
@@ -148,7 +148,7 @@ def __next__(self) -> Frame:
148
148
149
149
# At this point, as we know we'll use or discard the entire frame, we
150
150
# can update the data.
151
- self .data = self .data [9 + length :]
151
+ self ._data = self ._data [9 + length :]
152
152
153
153
# Pass the frame through the header buffer.
154
154
new_frame = self ._update_header_buffer (f )
0 commit comments