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

Expose reset method on NetStream

Browse Source
This commit is contained in:
Alex Stokes
2019-08-26 11:38:39 -07:00
parent 98a0e76dda
commit c5eda4065d
2 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
libp2p/network/stream/net_stream.py
View File

@ -50,3 +50,6 @@ class NetStream(INetStream):
""" """
await self.muxed_stream.close() await self.muxed_stream.close()
return True return True
async def reset(self) -> bool:
return await self.muxed_stream.reset()

6
libp2p/network/stream/net_stream_interface.py
View File

@ -42,3 +42,9 @@ class INetStream(ABC):
close the underlying muxed stream close the underlying muxed stream
:return: true if successful :return: true if successful
""" """
@abstractmethod
async def reset(self) -> bool:
"""
Close both ends of the stream.
"""