mirror of
https://github.com/zeromq/libzmq.git
synced 2025-11-03 00:23:30 +01:00
polling on SUB socket fixed
This commit is contained in:
@@ -150,10 +150,7 @@ int zmq::sub_t::xrecv (zmq_msg_t *msg_, int flags_)
|
|||||||
|
|
||||||
bool zmq::sub_t::xhas_in ()
|
bool zmq::sub_t::xhas_in ()
|
||||||
{
|
{
|
||||||
// TODO: This is more complex as we have to ignore all the messages that
|
return fq.has_in ();
|
||||||
// don't fit the filter.
|
|
||||||
zmq_assert (false);
|
|
||||||
return false;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
bool zmq::sub_t::xhas_out ()
|
bool zmq::sub_t::xhas_out ()
|
||||||
|
|||||||
Reference in New Issue
Block a user