subscriber.py 文件源码

def run(white_point):
    config = discover()
    downstream_url = config['downstream']

    socket = context.socket(zmq.SUB)
    socket.connect(config['downstream'])
    log.info("Connecting to %s" % downstream_url)

    socket.setsockopt_string(zmq.SUBSCRIBE, DEFAULT_CHANNEL)
    stream = ZMQStream(socket)

    loop = ioloop.IOLoop.instance()

    with blink1(white_point=white_point) as b1:
        reciever = Receiver(b1, loop)
        stream.on_recv(reciever.recieve)

        loop.add_callback(reciever.throbber)

        loop.start()