Add python-eventlet 0.16.1

[packages/trusty/python-eventlet.git] / eventlet / examples / zmq_simple.py

diff --git a/eventlet/examples/zmq_simple.py b/eventlet/examples/zmq_simple.py
new file mode 100644 (file)
index 0000000..6f5f11e
--- /dev/null
+++ b/eventlet/examples/zmq_simple.py
@@ -0,0 +1,33 @@
+from eventlet.green import zmq
+import eventlet
+
+CTX = zmq.Context(1)
+
+
+def bob_client(ctx, count):
+    print("STARTING BOB")
+    bob = zmq.Socket(CTX, zmq.REQ)
+    bob.connect("ipc:///tmp/test")
+
+    for i in range(0, count):
+        print("BOB SENDING")
+        bob.send("HI")
+        print("BOB GOT:", bob.recv())
+
+
+def alice_server(ctx, count):
+    print("STARTING ALICE")
+    alice = zmq.Socket(CTX, zmq.REP)
+    alice.bind("ipc:///tmp/test")
+
+    print("ALICE READY")
+    for i in range(0, count):
+        print("ALICE GOT:", alice.recv())
+        print("ALIC SENDING")
+        alice.send("HI BACK")
+
+alice = eventlet.spawn(alice_server, CTX, 10)
+bob = eventlet.spawn(bob_client, CTX, 10)
+
+bob.wait()
+alice.wait()