30 #ifndef __ZMQ_XPUB_HPP_INCLUDED__ 31 #define __ZMQ_XPUB_HPP_INCLUDED__ 66 int xsetsockopt (
int option_,
const void *optval_,
size_t optvallen_);
113 typedef std::basic_string <unsigned char>
blob_t;
std::deque< pipe_t * > pending_pipes
static void send_unsubscription(unsigned char *data_, size_t size_, void *arg_)
void xattach_pipe(zmq::pipe_t *pipe_, bool subscribe_to_all_=false)
std::deque< metadata_t * > pending_metadata
int xsend(zmq::msg_t *msg_)
std::deque< blob_t > pending_data
std::deque< unsigned char > pending_flags
const xpub_t & operator=(const xpub_t &)
xpub_t(zmq::ctx_t *parent_, uint32_t tid_, int sid_)
void xpipe_terminated(zmq::pipe_t *pipe_)
int xsetsockopt(int option_, const void *optval_, size_t optvallen_)
std::basic_string< unsigned char > blob_t
static void mark_as_matching(zmq::pipe_t *pipe_, void *arg_)
void xread_activated(zmq::pipe_t *pipe_)
void xwrite_activated(zmq::pipe_t *pipe_)
int xrecv(zmq::msg_t *msg_)