summaryrefslogtreecommitdiff
path: root/gr-zeromq/python/zeromq/qa_zeromq_sub_msg_source.py
diff options
context:
space:
mode:
Diffstat (limited to 'gr-zeromq/python/zeromq/qa_zeromq_sub_msg_source.py')
-rw-r--r--gr-zeromq/python/zeromq/qa_zeromq_sub_msg_source.py6
1 files changed, 4 insertions, 2 deletions
diff --git a/gr-zeromq/python/zeromq/qa_zeromq_sub_msg_source.py b/gr-zeromq/python/zeromq/qa_zeromq_sub_msg_source.py
index 3c98396087..10e7d5da84 100644
--- a/gr-zeromq/python/zeromq/qa_zeromq_sub_msg_source.py
+++ b/gr-zeromq/python/zeromq/qa_zeromq_sub_msg_source.py
@@ -48,8 +48,10 @@ class qa_zeromq_sub_msg_source(gr_unittest.TestCase):
"""Test receiving of valid PMT messages"""
msg = pmt.to_pmt('test_valid_pmt')
self.zmq_sock.send(pmt.serialize_str(msg))
-
- time.sleep(0.1)
+ for _ in range(10):
+ if self.message_debug.num_messages() > 0:
+ break
+ time.sleep(0.2)
self.assertEqual(1, self.message_debug.num_messages())
self.assertTrue(pmt.equal(msg, self.message_debug.get_message(0)))