INNER CODE UNIT · Rust

run_task

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

    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,
            );

            let stream = match resolve_stream(&task, &self.plugin_manager).await {
                Ok(s) => s,
                Err(e) => {
                    self.fail_task(&task_id, e);
                    return;
                }
            };

View source record →