varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2025-12-31 20:36:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #277 from ralexstokes/add-io-abstractions

Browse Source 
Introduces IO abstractions and classes for `msgio` IO
This commit is contained in:
Alex Stokes
2019-09-04 19:11:50 +02:00
committed by GitHub
parent e9ca372fb5 a764fd4e6f
commit 6d97702da7
7 changed files with 156 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
tests/security/test_secio.py
View File

@ -20,11 +20,12 @@ class InMemoryConnection(IRawConnection):
self.closed = False
async def write(self, data: bytes) -> None:
async def write(self, data: bytes) -> int:
if self.closed:
raise Exception("InMemoryConnection is closed for writing")
await self.send_queue.put(data)
return len(data)
async def read(self, n: int = -1) -> bytes:
"""