From e65e38a3f1fbdebcff1b71374ed2256ea48c441c Mon Sep 17 00:00:00 2001 From: Jinesh Jain <732005jinesh@gmail.com> Date: Tue, 8 Jul 2025 19:11:56 +0530 Subject: [PATCH] fix: linting error related to read --- libp2p/stream_muxer/mplex/mplex_stream.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/libp2p/stream_muxer/mplex/mplex_stream.py b/libp2p/stream_muxer/mplex/mplex_stream.py index 7c5dc6ab..9c5f04da 100644 --- a/libp2p/stream_muxer/mplex/mplex_stream.py +++ b/libp2p/stream_muxer/mplex/mplex_stream.py @@ -140,6 +140,7 @@ class MplexStream(IMuxedStream): :return: bytes actually read """ await self.rw_lock.acquire_read() + payload: bytes = b"" try: if n is not None and n < 0: raise ValueError( @@ -180,12 +181,12 @@ class MplexStream(IMuxedStream): "This should never happen." ) from error self._buf.extend(self._read_return_when_blocked()) - payload = self._buf[:n] - self._buf = self._buf[len(payload) :] - return bytes(payload) + chunk = self._buf[:n] + self._buf = self._buf[len(chunk) :] + payload = bytes(chunk) finally: await self.rw_lock.release_read() - return b"" + return payload async def write(self, data: bytes) -> None: """