Function run_start_if_idle

packages/server/src/logs.rs:46–72

(
    state: &Arc<LogStreamState>,
    start: F,
)

}

async fn run_start_if_idle<T, F, Fut>(
    state: &Arc<LogStreamState>,
    start: F,
) -> Result<Option<T>, AppError>
where
    F: FnOnce() -> Fut,
    Fut: Future<Output = Result<T, AppError>>,
{
    {
        let mut status = state.status.lock().await;
        if !matches!(status.phase, LogStreamPhase::Idle) {
            return Ok(None);
        }
        status.phase = LogStreamPhase::Starting;
    }

    match start().await {
        Ok(value) => {
            state.status.lock().await.phase = LogStreamPhase::Running;
            Ok(Some(value))
        }
        Err(error) => {
            state.status.lock().await.phase = LogStreamPhase::Idle;
            Err(error)
        }
    }
}

impl LogRegistry {
    pub fn new() -> Self {