(self, test_function_in, *, timeout=60, check_connected=True)
| 446 | # Connection helper methods |
| 447 | |
| 448 | def wait_until(self, test_function_in, *, timeout=60, check_connected=True): |
| 449 | def test_function(): |
| 450 | if check_connected: |
| 451 | assert self.is_connected |
| 452 | return test_function_in() |
| 453 | |
| 454 | wait_until_helper(test_function, timeout=timeout, lock=p2p_lock, timeout_factor=self.timeout_factor) |
| 455 | |
| 456 | def wait_for_connect(self, timeout=60): |
| 457 | test_function = lambda: self.is_connected |