diff options
| author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-29 07:53:33 +0100 |
|---|---|---|
| committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-29 07:53:33 +0100 |
| commit | 23e5c3b342793ca871747b7d6681d445b34925bb (patch) | |
| tree | 7ce8d599c2d12b212a7df08bafb980cbe99a928a | |
| parent | 72161fb075025410312c6735d681c3de9a36a4e5 (diff) | |
polling on SUB socket fixed
| -rw-r--r-- | src/sub.cpp | 5 |
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 () |