1#!/usr/bin/env python 2"""Adapted echo.py to put the send in the event loop using a ZMQStream. 3""" 4 5import zmq 6from zmq.eventloop import ioloop, zmqstream 7 8loop = ioloop.IOLoop.instance() 9 10ctx = zmq.Context() 11s = ctx.socket(zmq.ROUTER) 12s.bind('tcp://127.0.0.1:5555') 13stream = zmqstream.ZMQStream(s, loop) 14 15 16def echo(msg): 17 print(" ".join(map(repr, msg))) 18 stream.send_multipart(msg) 19 20 21stream.on_recv(echo) 22 23loop.start() 24