INNER CODE UNIT · Rust

Some

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

            if let Some(t) = manager.get_task(&task_id) {
                if let Ok(mut g) = t.lock() {
                    g.running = false;
                }
            }
        });
    }

    async fn run_task(&self, task_id: String) {
        for attempt in 0..=Self::MAX_RETRIES {
            let Some(task) = self.get_task(&task_id) else { return };

            self.set_task_state(
                &task_id,
                DownloadTaskState::Resolving,
                Some("Resolving stream".to_string()),
                None,
            );

View source record →