Fix mypy error
This commit is contained in:
parent
9889cb8ab1
commit
d52b093286
@ -146,7 +146,7 @@ class MplexStream(IMuxedStream):
|
||||
:return: number of bytes written
|
||||
"""
|
||||
if self.event_local_closed.is_set():
|
||||
raise MplexStreamClosed(f"cannot write to closed stream: data={data}")
|
||||
raise MplexStreamClosed(f"cannot write to closed stream: data={data!r}")
|
||||
flag = (
|
||||
HeaderTags.MessageInitiator
|
||||
if self.is_initiator
|
||||
|
@ -77,7 +77,7 @@ async def read_delim(reader: Reader) -> bytes:
|
||||
raise ParseError(f"`len(msg_bytes)` should not be 0")
|
||||
if msg_bytes[-1:] != b"\n":
|
||||
raise ParseError(
|
||||
f'`msg_bytes` is not delimited by b"\\n": `msg_bytes`={msg_bytes}'
|
||||
f'`msg_bytes` is not delimited by b"\\n": `msg_bytes`={msg_bytes!r}'
|
||||
)
|
||||
return msg_bytes[:-1]
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user