@@ -194,9 +194,8 @@ def _feed_data(self, data: bytes) -> None:
194
194
if self._max_msg_size and len(self._partial) >= self._max_msg_size:
195
195
raise WebSocketError(
196
196
WSCloseCode.MESSAGE_TOO_BIG,
197
- "Message size {} exceeds limit {}".format(
198
- len(self._partial), self._max_msg_size
199
- ),
197
+ f"Message size {len(self._partial)} "
198
+ f"exceeds limit {self._max_msg_size}",
200
199
)
201
200
continue
202
201
@@ -215,7 +214,7 @@ def _feed_data(self, data: bytes) -> None:
215
214
raise WebSocketError(
216
215
WSCloseCode.PROTOCOL_ERROR,
217
216
"The opcode in non-fin frame is expected "
218
- "to be zero, got {!r}".format(opcode) ,
217
+ f "to be zero, got {opcode !r}",
219
218
)
220
219
221
220
assembled_payload: Union[bytes, bytearray]
@@ -228,9 +227,8 @@ def _feed_data(self, data: bytes) -> None:
228
227
if self._max_msg_size and len(assembled_payload) >= self._max_msg_size:
229
228
raise WebSocketError(
230
229
WSCloseCode.MESSAGE_TOO_BIG,
231
- "Message size {} exceeds limit {}".format(
232
- len(assembled_payload), self._max_msg_size
233
- ),
230
+ f"Message size {len(assembled_payload)} "
231
+ f"exceeds limit {self._max_msg_size}",
234
232
)
235
233
236
234
# Decompress process must to be done after all packets
@@ -247,9 +245,8 @@ def _feed_data(self, data: bytes) -> None:
247
245
left = len(self._decompressobj.unconsumed_tail)
248
246
raise WebSocketError(
249
247
WSCloseCode.MESSAGE_TOO_BIG,
250
- "Decompressed message size {} exceeds limit {}".format(
251
- self._max_msg_size + left, self._max_msg_size
252
- ),
248
+ f"Decompressed message size {self._max_msg_size + left}"
249
+ f" exceeds limit {self._max_msg_size}",
253
250
)
254
251
elif type(assembled_payload) is bytes:
255
252
payload_merged = assembled_payload
0 commit comments