From d3a948be476ea2771615606d9c0e060106bf21f6 Mon Sep 17 00:00:00 2001 From: mhchia Date: Wed, 24 Jul 2019 16:24:14 +0800 Subject: [PATCH] Fix error: Change params floodsub.publish back --- libp2p/pubsub/floodsub.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/libp2p/pubsub/floodsub.py b/libp2p/pubsub/floodsub.py index 949b929..c056214 100644 --- 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