zmqstream.py 291 B

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