INNER CODE UNIT · Rust

acknowledge_persisted

HemantKArya/BloomeeTunes · rust/src/api/downloader/mod.rs:350

    pub async fn acknowledge_persisted(&self, task_id: String) -> bool {
        self.remove_task(&task_id)
    }

    // ── Internal: task spawning / execution ───────────────────────────────────

    fn spawn_worker(&self, task_id: String) {
        let Some(task) = self.get_task(&task_id) else { return };

        {
            let Ok(mut g) = task.lock() else { return };
            if g.running || matches!(g.persisted.state, DownloadTaskState::CompletedPendingAck) {
                return;
            }
            g.running = true;
            g.pause_requested.store(false, Ordering::Release);
            g.cancel_requested.store(false, Ordering::Release);
            if matches!(g.persisted.state, DownloadTaskState::Failed | DownloadTaskState::Paused) {

View source record →