varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2026-02-12 16:10:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #74 from csunny/master

Browse Source 
chat example run error
This commit is contained in:
Robert Zajac
2018-11-28 13:06:42 -05:00
committed by GitHub
parent f8963d628c c950e065f3
commit 64cd495ddb
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
examples/chat/chat.py
View File

@ -1,4 +1,4 @@
#!/bin/env python3 #!/usr/bin/env python3
import sys import sys
from os.path import dirname, abspath from os.path import dirname, abspath
sys.path.append(dirname(dirname(dirname(abspath(__file__))))) sys.path.append(dirname(dirname(dirname(abspath(__file__)))))
@ -23,7 +23,7 @@ async def read_data(stream):
if read_string != "\n": if read_string != "\n":
# Green console colour: \x1b[32m # Green console colour: \x1b[32m
# Reset console colour: \x1b[0m # Reset console colour: \x1b[0m
print("\x1b[32m%s\x1b[0m" % read_string) print("\x1b[32m%s\x1b[0m> " % read_string, end="")
async def write_data(stream): async def write_data(stream):
@ -60,6 +60,7 @@ async def run(port, destination):
print("You can replace 127.0.0.1 with public IP as well.") print("You can replace 127.0.0.1 with public IP as well.")
print("\nWaiting for incoming connection\n\n") print("\nWaiting for incoming connection\n\n")
else: else:
host = await new_node(transport_opt=["/ip4/127.0.0.1/tcp/%s/p2p/hostB" % port]) host = await new_node(transport_opt=["/ip4/127.0.0.1/tcp/%s/p2p/hostB" % port])
@ -78,6 +79,7 @@ async def run(port, destination):
asyncio.ensure_future(read_data(stream)) asyncio.ensure_future(read_data(stream))
asyncio.ensure_future(write_data(stream)) asyncio.ensure_future(write_data(stream))
print("Already connected to peer %s" % addr)
@click.command() @click.command()