Function assert_equal

tests/sync/test_route_web_socket.py:23–36

(
    actual_cb: Callable[[], Union[Any, Awaitable[Any]]], expected: Any
)

def assert_equal(
    actual_cb: Callable[[], Union[Any, Awaitable[Any]]], expected: Any
) -> None:
    __tracebackhide__ = True
    start_time = time.time()
    attempts = 0
    while True:
        actual = actual_cb()
        if actual == expected:
            return
        attempts += 1
        if time.time() - start_time > 10:
            raise TimeoutError(f"Timed out after 10 seconds. Last actual was: {actual}")
        time.sleep(0.1)


def setup_ws(