INNER CODE UNIT · Rust

get_task

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

    fn get_task(&self, task_id: &str) -> Option<Arc<Mutex<ManagedTask>>> {
        self.tasks.read().ok()?.get(task_id).cloned()
    }

    fn snapshot_for(&self, task_id: &str) -> Option<DownloadTaskSnapshot> {
        let task = self.get_task(task_id)?;
        let g = task.lock().ok()?;
        Some(DownloadTaskSnapshot::from_persisted(&g.persisted))
    }

    // ── Internal: event emission ──────────────────────────────────────────────

    fn emit(&self, event: DownloadManagerEvent) {
        if let Ok(mut hub) = self.event_hub.lock() {
            hub.emit(event);
        }
    }

View source record →