fix assert error on late-joining subscriber after publisher has fille…

…d NORM buffer
SChernykh · Jul 21, 2023 · ec013f3 · ec013f3
1 parent ecc63d0
commit ec013f3
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/norm_engine.cpp b/src/norm_engine.cpp
@@ -557,8 +557,7 @@ void zmq::norm_engine_t::recv_data (NormObjectHandle object)
                 char syncFlag;
                 unsigned int numBytes = 1;
                 if (!NormStreamRead (stream, &syncFlag, &numBytes)) {
-                    // broken stream (shouldn't happen after seek msg start?)
-                    zmq_assert (false);
+                    // broken stream (can happen on late-joining subscriber)
                     continue;
                 }
                 if (0 == numBytes) {