varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2026-02-12 16:10:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: linting error related to read

Browse Source
This commit is contained in:
Jinesh Jain
2025-07-08 19:11:56 +05:30
parent 8fb664bfdf
commit e65e38a3f1
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
libp2p/stream_muxer/mplex/mplex_stream.py
View File

@ -140,6 +140,7 @@ class MplexStream(IMuxedStream):
:return: bytes actually read :return: bytes actually read
""" """
await self.rw_lock.acquire_read() await self.rw_lock.acquire_read()
payload: bytes = b""
try: try:
if n is not None and n < 0: if n is not None and n < 0:
raise ValueError( raise ValueError(
@ -180,12 +181,12 @@ class MplexStream(IMuxedStream):
"This should never happen." "This should never happen."
) from error ) from error
self._buf.extend(self._read_return_when_blocked()) self._buf.extend(self._read_return_when_blocked())
payload = self._buf[:n] chunk = self._buf[:n]
self._buf = self._buf[len(payload) :] self._buf = self._buf[len(chunk) :]
return bytes(payload) payload = bytes(chunk)
finally: finally:
await self.rw_lock.release_read() await self.rw_lock.release_read()
return b"" return payload
async def write(self, data: bytes) -> None: async def write(self, data: bytes) -> None:
""" """