Function _wait_for

python/e2e/test_rpc_session_state_e2e.py:87–93

(condition, *, timeout: float = 15.0, message: str)

async def _wait_for(condition, *, timeout: float = 15.0, message: str):
    deadline = time.monotonic() + timeout
    while time.monotonic() < deadline:
        if await condition():
            return
        await asyncio.sleep(0.2)
    pytest.fail(message)


async def _assert_implemented_failure(awaitable, method: str) -> None: