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

Merge pull request #310 from mhchia/fix/missing_await_for_stream_reset_in_pubsub

Browse Source 
Add the missing `await` for `stream.reset` in pubsub
This commit is contained in:
Kevin Mai-Husan Chia
2019-09-24 14:04:25 +08:00
committed by GitHub
parent b53ca5708f b0c919aab7
commit dbc35e8b9d
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
libp2p/pubsub/pubsub.py
View File

@ -245,7 +245,7 @@ class Pubsub:
await self.continuously_read_stream(stream) await self.continuously_read_stream(stream)
except (StreamEOF, StreamReset) as error: except (StreamEOF, StreamReset) as error:
logger.debug("fail to read from stream, error=%s", error) logger.debug("fail to read from stream, error=%s", error)
stream.reset() await stream.reset()
# TODO: what to do when the stream is terminated? # TODO: what to do when the stream is terminated?
# disconnect the peer? # disconnect the peer?