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

sync handle_rpc docstring

Browse Source
This commit is contained in:
pacrob
2024-12-03 11:08:32 -07:00
committed by Paul Robinson
parent f156668c1b
commit 33332d7106
3 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
libp2p/pubsub/abc.py
View File

@ -83,7 +83,7 @@ class IPubsubRouter(ABC):
Invoked to process control messages in the RPC envelope.
It is invoked after subscriptions and payload messages have been processed
:param rpc: rpc message
:param rpc: RPC message
:param sender_peer_id: id of the peer who sent the message
"""

7
libp2p/pubsub/floodsub.py
View File

@ -75,10 +75,11 @@ class FloodSub(IPubsubRouter):
async def handle_rpc(self, rpc: rpc_pb2.RPC, sender_peer_id: ID) -> None:
"""
Invoked to process control messages in the RPC envelope. It is invoked
after subscriptions and payload messages have been processed.
Invoked to process control messages in the RPC envelope.
It is invoked after subscriptions and payload messages have been processed
:param rpc: rpc message
:param rpc: RPC message
:param sender_peer_id: id of the peer who sent the message
"""
# Checkpoint
await trio.lowlevel.checkpoint()

4
libp2p/pubsub/gossipsub.py
View File

@ -179,8 +179,8 @@ class GossipSub(IPubsubRouter, Service):
async def handle_rpc(self, rpc: rpc_pb2.RPC, sender_peer_id: ID) -> None:
"""
Invoked to process control messages in the RPC envelope. It is invoked
after subscriptions and payload messages have been processed.
Invoked to process control messages in the RPC envelope.
It is invoked after subscriptions and payload messages have been processed
:param rpc: RPC message
:param sender_peer_id: id of the peer who sent the message