detach() | ZmqMessage::Sink | [inline] |
dst() | ZmqMessage::Sink | [inline] |
flush() | ZmqMessage::Sink | |
incoming() const | ZmqMessage::Sink | [inline] |
is_dropping() const | ZmqMessage::Sink | [inline] |
is_queued() const | ZmqMessage::Sink | [inline] |
NonCopyable() | ZmqMessage::Private::NonCopyable | [inline, private] |
operator<<(const T &t) | ZmqMessage::Sink | |
operator<<(zmq::message_t &msg) | ZmqMessage::Sink | |
operator<<(MsgPtr msg) | ZmqMessage::Sink | [inline] |
operator<<(const RawMessage &m) | ZmqMessage::Sink | |
operator<<(Sink &(*f)(Sink &)) | ZmqMessage::Sink | [inline] |
options() const | ZmqMessage::Sink | [inline, protected] |
relay_from(zmq::socket_t &relay_src) | ZmqMessage::Sink | |
relay_from(zmq::socket_t &relay_src, OccupationAccumulator acc) | ZmqMessage::Sink | |
send_incoming_messages(size_t idx_from=0, size_t idx_to=UINT_MAX) | ZmqMessage::Sink | |
send_incoming_messages(Multipart &multipart, bool copy, size_t idx_from=0, size_t idx_to=UINT_MAX) | ZmqMessage::Sink | |
send_one(zmq::message_t *msg, bool use_copy=false) | ZmqMessage::Sink | [protected] |
set_binary() | ZmqMessage::Sink | [inline] |
set_text() | ZmqMessage::Sink | [inline] |
Sink(zmq::socket_t &dst, unsigned options, Multipart *incoming=0) | ZmqMessage::Sink | [inline, protected] |
~NonCopyable() | ZmqMessage::Private::NonCopyable | [inline, private] |
~Sink() | ZmqMessage::Sink | [virtual] |