Method schedule_save

src/utils/runtime.rs:47–116

(&self, value: T)

    }

    pub fn schedule_save(&self, value: T) {
        let should_spawn = {
            let mut state = self.state.lock().expect("persistence state poisoned");
            state.pending = Some(value);

            if state.task_running {
                false
            } else {
                state.task_running = true;
                true
            }
        };

        if !should_spawn {
            return;
        }

        let label = self.label;
        let path = self.path.clone();
        let delay = self.delay;
        let state = self.state.clone();

        self.runtime.spawn(async move {
            loop {
                sleep(delay).await;

                let snapshot = {
                    let mut state = state.lock().expect("persistence state poisoned");
                    state.pending.take()
                };

                let Some(snapshot) = snapshot else {
                    let mut state = state.lock().expect("persistence state poisoned");
                    state.task_running = false;
                    return;
                };

                if let Some(parent) = path.parent()
                    && let Err(err) = tokio::fs::create_dir_all(parent).await
                {
                    log::error!("Failed to create {} storage directory: {}", label, err);
                }

                match serde_json::to_string(&snapshot) {
                    Ok(contents) => {
                        if let Err(err) = tokio::fs::write(&path, contents).await {
                            log::error!("Failed to save {}: {}", label, err);
                        }
                    }
                    Err(err) => {
                        log::error!("Failed to serialize {}: {}", label, err);
                    }
                }

                let should_continue = {
                    let mut state = state.lock().expect("persistence state poisoned");
                    if state.pending.is_some() {
                        true