|
|
|
@ -108,7 +108,7 @@ pub async fn work(conf: config::Config) -> Result<(), Box<dyn std::error::Error>
|
|
|
|
|
prog_send!(link unwind prog.push_task(&task));
|
|
|
|
|
|
|
|
|
|
let temp = tempfile::TempFile::new();
|
|
|
|
|
let return_value = 'clean: {
|
|
|
|
|
let return_value = loop {
|
|
|
|
|
match perform(&url, &temp, &mut prog).await {
|
|
|
|
|
Err(e) => prog_send!(link prog.println(format!("Failed downloading {} -> {:?}: {}", url, temp, e))),
|
|
|
|
|
Ok(_) => {
|
|
|
|
@ -120,15 +120,15 @@ pub async fn work(conf: config::Config) -> Result<(), Box<dyn std::error::Error>
|
|
|
|
|
Ok(v) => v,
|
|
|
|
|
Err(e) => {
|
|
|
|
|
prog_send!(link prog.println(format!("Failed decoding: {}", e)));
|
|
|
|
|
break 'clean Some(e);
|
|
|
|
|
break Some(e);
|
|
|
|
|
},
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
prog_send!(link prog.println(format!("{:?} Complete", loli)));
|
|
|
|
|
break 'clean None;
|
|
|
|
|
break None;
|
|
|
|
|
},
|
|
|
|
|
};
|
|
|
|
|
Some(error::Error::Unknown)
|
|
|
|
|
break Some(error::Error::Unknown);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
prog_send!(link prog.pop_task(task));
|
|
|
|
|