30 #ifndef __ZMQ_XSUB_HPP_INCLUDED__ 31 #define __ZMQ_XSUB_HPP_INCLUDED__
void xread_activated(zmq::pipe_t *pipe_)
void xwrite_activated(zmq::pipe_t *pipe_)
static void send_subscription(unsigned char *data_, size_t size_, void *arg_)
void xattach_pipe(zmq::pipe_t *pipe_, bool subscribe_to_all_)
void xpipe_terminated(zmq::pipe_t *pipe_)
bool match(zmq::msg_t *msg_)
const xsub_t & operator=(const xsub_t &)
blob_t get_credential() const
std::basic_string< unsigned char > blob_t
int xsend(zmq::msg_t *msg_)
xsub_t(zmq::ctx_t *parent_, uint32_t tid_, int sid_)
void xhiccuped(pipe_t *pipe_)
int xrecv(zmq::msg_t *msg_)