+++ /dev/null
-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()