()
| 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 |