From 7d5c3dcd969161322deed6c43f8a6a3cb92c3369 Mon Sep 17 00:00:00 2001 From: Micah Anderson Date: Tue, 11 Nov 2014 11:53:55 -0500 Subject: upgrade to 14.4.1 --- examples/eventloop/echostream.py | 24 ++++++++++++++++++++++++ 1 file changed, 24 insertions(+) create mode 100644 examples/eventloop/echostream.py (limited to 'examples/eventloop/echostream.py') diff --git a/examples/eventloop/echostream.py b/examples/eventloop/echostream.py new file mode 100644 index 0000000..04c1532 --- /dev/null +++ b/examples/eventloop/echostream.py @@ -0,0 +1,24 @@ +#!/usr/bin/env python +"""Adapted echo.py to put the send in the event loop using a ZMQStream. + +Authors +------- +* MinRK +""" + +import zmq +from zmq.eventloop import ioloop, zmqstream +loop = ioloop.IOLoop.instance() + +ctx = zmq.Context() +s = ctx.socket(zmq.REP) +s.bind('tcp://127.0.0.1:5555') +stream = zmqstream.ZMQStream(s, loop) + +def echo(msg): + print " ".join(msg) + stream.send_multipart(msg) + +stream.on_recv(echo) + +loop.start() \ No newline at end of file -- cgit v1.2.3