summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-12-29 07:53:33 +0100
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-12-29 07:53:33 +0100
commit23e5c3b342793ca871747b7d6681d445b34925bb (patch)
tree7ce8d599c2d12b212a7df08bafb980cbe99a928a
parent72161fb075025410312c6735d681c3de9a36a4e5 (diff)
polling on SUB socket fixed
-rw-r--r--src/sub.cpp5
1 files changed, 1 insertions, 4 deletions
diff --git a/src/sub.cpp b/src/sub.cpp
index 95039d7..b2174c5 100644
--- a/src/sub.cpp
+++ b/src/sub.cpp
@@ -150,10 +150,7 @@ int zmq::sub_t::xrecv (zmq_msg_t *msg_, int flags_)
bool zmq::sub_t::xhas_in ()
{
- // TODO: This is more complex as we have to ignore all the messages that
- // don't fit the filter.
- zmq_assert (false);
- return false;
+ return fq.has_in ();
}
bool zmq::sub_t::xhas_out ()