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