1 from eventlet.green import zmq
7 def bob_client(ctx, count):
9 bob = zmq.Socket(CTX, zmq.REQ)
10 bob.connect("ipc:///tmp/test")
12 for i in range(0, count):
15 print("BOB GOT:", bob.recv())
18 def alice_server(ctx, count):
19 print("STARTING ALICE")
20 alice = zmq.Socket(CTX, zmq.REP)
21 alice.bind("ipc:///tmp/test")
24 for i in range(0, count):
25 print("ALICE GOT:", alice.recv())
29 alice = eventlet.spawn(alice_server, CTX, 10)
30 bob = eventlet.spawn(bob_client, CTX, 10)