Function wait_for_content

python/e2e/test_session_fs_e2e.py:658–662

(path: Path, expected: str, timeout: float = 5.0)

async def wait_for_content(path: Path, expected: str, timeout: float = 5.0) -> None:
    async def predicate():
        return path.exists() and expected in path.read_text(encoding="utf-8")

    await wait_for_predicate(predicate, timeout=timeout)


async def wait_for_predicate(predicate, timeout: float = 5.0) -> None: