(
client: reqwest::Client,
prefetch_tx: Sender<PrefetchReq>,
url: &Url,
submit_tx: &Sender<CacheMeta>,
file: NamedTempFile,
obj: &CacheObj<PathBuf, Status>,
prefetch_paths:
| 345 | |
| 346 | #[instrument(skip_all)] |
| 347 | fn async_refresh( |
| 348 | client: reqwest::Client, |
| 349 | prefetch_tx: Sender<PrefetchReq>, |
| 350 | url: &Url, |
| 351 | submit_tx: &Sender<CacheMeta>, |
| 352 | file: NamedTempFile, |
| 353 | obj: &CacheObj<PathBuf, Status>, |
| 354 | prefetch_paths: Option<Vec<PrefetchItem>>, |
| 355 | ) { |
| 356 | let u = url.clone(); |
| 357 | let tx = submit_tx.clone(); |
| 358 | let obj = obj.clone(); |
| 359 | tokio::spawn(async move { |
| 360 | async_refresh_task(client, prefetch_tx, u, tx, file, obj, prefetch_paths).await |
| 361 | }); |
| 362 | } |
| 363 | |
| 364 | #[instrument(skip_all)] |
| 365 | async fn async_refresh_task( |
no test coverage detected