perf tests modified to reflect change in subscription format

1 files changed, 5 insertions, 3 deletions

diff --git a/src/zmq_engine.cpp b/src/zmq_engine.cpp
index 40cedfb..a79c0bd 100644
--- a/src/zmq_engine.cpp
+++ b/src/zmq_engine.cpp
@@ -102,9 +102,11 @@ void zmq::zmq_engine_t::in_event ()
 
     //  Stop polling for input if we got stuck.
     if (processed < insize) {
-        zmq_assert (false);
-        //  TODO: This may happen is queue limits are implemented.
-        //  reset_pollin (handle);
+
+        //  This may happen if queue limits are implemented or when
+        //  init object reads all required information from the socket
+        //  and rejects to read more data.
+        reset_pollin (handle);
     }
 
     //  Flush all messages the decoder may have produced.