Function wait_healthcheck

apps/hash-graph/src/subcommand/mod.rs:184–208

(
    func: F,
    args: &HealthcheckArgs,
)

}

pub async fn wait_healthcheck<F, Ret>(
    func: F,
    args: &HealthcheckArgs,
) -> Result<(), Report<HealthcheckError>>
where
    F: Fn() -> Ret + Send,
    Ret: Future<Output = Result<(), Report<HealthcheckError>>> + Send,
{
    let expected_end_time = args
        .timeout
        .map(|timeout| Instant::now() + Duration::from_secs(timeout));

    loop {
        if func().await.is_ok() {
            return Ok(());
        }
        ensure!(args.wait, HealthcheckError::NotHealthy);
        if let Some(end_time) = expected_end_time
            && Instant::now() > end_time
        {
            return Err(HealthcheckError::Timeout.into());
        }
        sleep(Duration::from_secs(1)).await;
    }
}