Simple echo client/server example (for Twitter thread).

2 files changed, 36 insertions, 0 deletions

diff --git a/examples/echo_client_tulip.py b/examples/echo_client_tulip.py
new file mode 100644
index 0000000..9b5d29b
--- /dev/null
+++ b/examples/echo_client_tulip.py
@@ -0,0 +1,19 @@
+import asyncio
+
+END = b'Bye-bye!\n'
+
+@asyncio.coroutine
+def echo_client():
+    reader, writer = yield from asyncio.open_connection('localhost', 8000)
+    writer.write(b'Hello, world\n')
+    writer.write(b'What a fine day it is.\n')
+    writer.write(END)
+    while True:
+        line = yield from reader.readline()
+        print('received:', line)
+        if line == END or not line:
+            break
+    writer.close()
+
+loop = asyncio.get_event_loop()
+loop.run_until_complete(echo_client())
diff --git a/examples/echo_server_tulip.py b/examples/echo_server_tulip.py
new file mode 100644
index 0000000..c1ccb9d
--- /dev/null
+++ b/examples/echo_server_tulip.py
@@ -0,0 +1,17 @@
+import asyncio
+
+@asyncio.coroutine
+def echo_server():
+    yield from asyncio.start_server(handle_connection, 'localhost', 8000)
+
+@asyncio.coroutine
+def handle_connection(reader, writer):
+    while True:
+        data = yield from reader.read(8192)
+        if not data:
+            break
+        writer.write(data)
+
+loop = asyncio.get_event_loop()
+loop.run_until_complete(echo_server())
+loop.run_forever()