From 33332d71060d11c1db3f99200582e19e8f42f573 Mon Sep 17 00:00:00 2001 From: pacrob <5199899+pacrob@users.noreply.github.com> Date: Tue, 3 Dec 2024 11:08:32 -0700 Subject: [PATCH] sync handle_rpc docstring --- libp2p/pubsub/abc.py | 2 +- libp2p/pubsub/floodsub.py | 7 ++++--- libp2p/pubsub/gossipsub.py | 4 ++-- 3 files changed, 7 insertions(+), 6 deletions(-) diff --git a/libp2p/pubsub/abc.py b/libp2p/pubsub/abc.py index 8c6ce6a5..b7856fea 100644 --- a/libp2p/pubsub/abc.py +++ b/libp2p/pubsub/abc.py @@ -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 """ diff --git a/libp2p/pubsub/floodsub.py b/libp2p/pubsub/floodsub.py index 41628b3b..c73e5858 100644 --- a/libp2p/pubsub/floodsub.py +++ b/libp2p/pubsub/floodsub.py @@ -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() diff --git a/libp2p/pubsub/gossipsub.py b/libp2p/pubsub/gossipsub.py index cabed25b..3c10beb6 100644 --- a/libp2p/pubsub/gossipsub.py +++ b/libp2p/pubsub/gossipsub.py @@ -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