zmqstream.py 308 B

1234567891011
  1. from zmq.eventloop.zmqstream import *
  2. from zmq.green.eventloop.ioloop import IOLoop
  3. RealZMQStream = ZMQStream
  4. class ZMQStream(RealZMQStream):
  5. def __init__(self, socket, io_loop=None):
  6. io_loop = io_loop or IOLoop.instance()
  7. super(ZMQStream, self).__init__(socket, io_loop=io_loop)