check the buffer length

Signed-off-by: Pintaudi Giorgio <[email protected]>
ros2 · Mar 13, 2023 · 8249e34 · 8249e34
1 parent 7c9e181
commit 8249e34
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/launch_testing_ros/test/examples/wait_for_topic_launch_test.py b/launch_testing_ros/test/examples/wait_for_topic_launch_test.py
@@ -68,6 +68,7 @@ def test_topics_successful(self, count):
                 assert wait_for_node_object_1.topics_received() == expected_topics
                 assert wait_for_node_object_1.topics_not_received() == set()
                 for topic_name, _ in topic_list:
+                    assert len(wait_for_node_object_1.received_messages(topic_name)) >= 1
                     message = wait_for_node_object_1.received_messages(topic_name).pop().data
                     assert message_pattern.match(message)
 
@@ -79,6 +80,7 @@ def test_topics_successful(self, count):
             assert wait_for_node_object_2.topics_received() == expected_topics
             assert wait_for_node_object_2.topics_not_received() == set()
             for topic_name, _ in topic_list:
+                assert len(wait_for_node_object_1.received_messages(topic_name)) >= 1
                 message = wait_for_node_object_2.received_messages(topic_name).pop().data
                 assert message_pattern.match(message)
             wait_for_node_object_2.shutdown()