pub async fn wait_until_client_state<F: Fn(ClientStateSummary) -> bool>(
    client_state_update_stream: &mut ClientStateUpdatesRequestStream,
    continue_fn: F
)