(self, test_function_in, *, timeout=60, check_connected=True, check_interval=0.05)
| 602 | # Connection helper methods |
| 603 | |
| 604 | def wait_until(self, test_function_in, *, timeout=60, check_connected=True, check_interval=0.05): |
| 605 | def test_function(): |
| 606 | if check_connected: |
| 607 | assert self.is_connected |
| 608 | return test_function_in() |
| 609 | |
| 610 | wait_until_helper_internal(test_function, timeout=timeout, lock=p2p_lock, timeout_factor=self.timeout_factor, check_interval=check_interval) |
| 611 | |
| 612 | def wait_for_connect(self, *, timeout=60): |
| 613 | test_function = lambda: self.is_connected |