From ebda40e034cdae1f38aecbddda94bb39f97eefd2 Mon Sep 17 00:00:00 2001 From: Stuckinaboot Date: Tue, 9 Apr 2019 21:12:51 -0400 Subject: [PATCH] Add print statements to receiver --- examples/sharding/receiver.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/examples/sharding/receiver.py b/examples/sharding/receiver.py index 6200a18..f9cdd7c 100644 --- a/examples/sharding/receiver.py +++ b/examples/sharding/receiver.py @@ -57,10 +57,15 @@ class ReceiverNode(): print("End received") async def start_receiving(self, sender_node_info): + print("Receiving started") + await self.libp2p_node.connect(sender_node_info) + print("Connection to sender confirmed") ack_stream = await self.libp2p_node.new_stream(sender_node_info.peer_id, [self.ack_protocol]) + print("Ack stream created") asyncio.ensure_future(self.wait_for_end(ack_stream)) + print("Listening for ack messages") self.should_listen = True ack_msg = self.topic encoded_ack_msg = ack_msg.encode()