Fix error: Change params floodsub.publish back

2019-07-24 16:24:14 +08:00 · 2019-07-24 16:24:14 +08:00 · d3a948be47
commit d3a948be47
parent 8da4032c3b
1 changed files with 1 additions and 1 deletions
--- a/libp2p/pubsub/floodsub.py
+++ b/libp2p/pubsub/floodsub.py
@ -46,7 +46,7 @@ class FloodSub(IPubsubRouter):
        :param rpc: rpc message
        """

-    async def publish(self, from_peer: ID, pubsub_message: rpc_pb2.Message) -> None:
+    async def publish(self, sender_peer_id: ID, rpc_message: rpc_pb2.Message) -> None:
        """
        Invoked to forward a new message that has been validated.
        This is where the "flooding" part of floodsub happens