Wait for values to be queued when testing async ValueComm

Author: langmm

yggdrasil/communication/tests/test_ValueComm.py

@@ -43,6 +43,9 @@ def test_send_recv(self):
         n_recv = self.testing_options['kwargs']['count']
         msg_recv = self.test_msg
         if self.use_async:
+            from yggdrasil.multitasking import wait_on_function
+            wait_on_function(lambda: self.recv_instance.n_msg_recv > 0,
+                             timeout=self.timeout)
             assert(self.recv_instance.n_msg_recv > 0)
         else:
             self.assert_equal(self.recv_instance.n_msg_recv, n_recv)