diff --git a/libp2p/stream_muxer/mplex/mplex_stream.py b/libp2p/stream_muxer/mplex/mplex_stream.py index 7cc0564e..897f3216 100644 --- a/libp2p/stream_muxer/mplex/mplex_stream.py +++ b/libp2p/stream_muxer/mplex/mplex_stream.py @@ -146,7 +146,7 @@ async def write(self, data: bytes) -> int: :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 diff --git a/libp2p/utils.py b/libp2p/utils.py index 39c79e58..aeb7ae3b 100644 --- a/libp2p/utils.py +++ b/libp2p/utils.py @@ -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]