From 686c55b09c56c4403112cdf8b4185e937dc6d198 Mon Sep 17 00:00:00 2001 From: Stuckinaboot Date: Fri, 5 Apr 2019 17:38:29 -0400 Subject: [PATCH] Remove unnecessary print #146 --- libp2p/pubsub/floodsub.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/libp2p/pubsub/floodsub.py b/libp2p/pubsub/floodsub.py index a4f2e86c..14394c71 100644 --- a/libp2p/pubsub/floodsub.py +++ b/libp2p/pubsub/floodsub.py @@ -74,13 +74,12 @@ class FloodSub(IPubsubRouter): # message sender and are not the message origin if peer_id_in_topic not in (msg_sender, decoded_from_id): stream = self.pubsub.peers[peer_id_in_topic] - # create new packet with just publish message + # Create new packet with just publish message new_packet = rpc_pb2.RPC() new_packet.publish.extend([message]) + + # Publish the packet await stream.write(new_packet.SerializeToString()) - else: - # Implies publish did not write - print("publish did not write") def join(self, topic): """