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

Iterate dead_peer_receive_channel with async for

Browse Source
This commit is contained in:
mhchia
2019-12-26 20:44:32 +08:00
parent 68c84b273d
commit 94f0fcb6ad
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
libp2p/pubsub/pubsub.py
View File

@ -332,8 +332,7 @@ class Pubsub(IPubsub, Service):
open a stream to the peer using a supported pubsub protocol pubsub open a stream to the peer using a supported pubsub protocol pubsub
protocols we support.""" protocols we support."""
async with self.peer_receive_channel: async with self.peer_receive_channel:
while self.manager.is_running: async for peer_id in self.peer_receive_channel:
peer_id: ID = await self.peer_receive_channel.receive()
# Add Peer # Add Peer
self.manager.run_task(self._handle_new_peer, peer_id) self.manager.run_task(self._handle_new_peer, peer_id)
@ -342,8 +341,7 @@ class Pubsub(IPubsub, Service):
between that peer and remove peer info from pubsub and pubsub between that peer and remove peer info from pubsub and pubsub
router.""" router."""
async with self.dead_peer_receive_channel: async with self.dead_peer_receive_channel:
while self.manager.is_running: async for peer_id in self.dead_peer_receive_channel:
peer_id: ID = await self.dead_peer_receive_channel.receive()
# Remove Peer # Remove Peer
self._handle_dead_peer(peer_id) self._handle_dead_peer(peer_id)