zmqlib.py 文件源码

def send_changes(socket, discussion, changeset):
    order = next(_counter)
    socket.send(str(discussion).encode('ascii'), zmq.SNDMORE)
    socket.send(str(order).encode('ascii'), zmq.SNDMORE)
    socket.send_json(changeset)
    log.debug("sent %d %s %s " % (order, discussion, changeset))