zeronimo/messaging.py
def recv(socket, flags=0, capture=(lambda msgs: None)):
    """Receives header, payload, and topics through a ZeroMQ socket.

    :param socket: a zmq socket.
    :param flags: zmq flags to receive messages.
    :param capture: a function to capture received messages.

    """
    msgs = eintr_retry_zmq(socket.recv_multipart, flags)
    capture(msgs)
    return parse(msgs)
def recv(socket, flags=0, capture=(lambda msgs: None)):
    msgs = eintr_retry_zmq(socket.recv_multipart, flags)
    capture(msgs)
    return parse(msgs)
def recv ( socket , flags = 0 , capture = ( lambda msgs : None ) ) : msgs = eintr_retry_zmq ( socket . recv_multipart , flags ) capture ( msgs ) return parse ( msgs )
Receives header, payload, and topics through a ZeroMQ socket.

    :param socket: a zmq socket.
    :param flags: zmq flags to receive messages.
    :param capture: a function to capture received messages.
Receives header payload and topics through a ZeroMQ socket .