(self)
| 62 | assert server_queue.get(timeout=5.0) == ("notify_finished", more) |
| 63 | |
| 64 | def hello(self): |
| 65 | def _hello(): |
| 66 | try: |
| 67 | msg = runner.proxy.hello("ignored") |
| 68 | if msg is not None: |
| 69 | if isinstance(msg, (list, tuple)): |
| 70 | msg = next(iter(msg)) |
| 71 | if msg.lower().startswith("hello"): |
| 72 | return True |
| 73 | except: |
| 74 | # That's ok, communication still not ready. |
| 75 | pass |
| 76 | |
| 77 | return False |
| 78 | |
| 79 | wait_for_condition(_hello) |
| 80 | |
| 81 | def close(self): |
| 82 | try: |
no test coverage detected