perf: use tokio tasks

pnpm · Nov 6, 2023 · 92d5949 · 92d5949
1 parent 8c38feb
commit 92d5949
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/crates/tarball/src/lib.rs b/crates/tarball/src/lib.rs
@@ -262,13 +262,15 @@ impl<'a> DownloadTarballToStore<'a> {
 
                 Ok::<_, TarballError>(((cleaned_entry_path, file_path), (index_key, index_value)))
             })
+            .map(tokio::task::spawn)
             .pipe(futures_util::future::join_all)
             .await;
 
         let mut cas_paths = HashMap::<OsString, PathBuf>::with_capacity(entries.len());
         let mut pkg_files_idx = PackageFilesIndex { files: HashMap::with_capacity(entries.len()) };
         for entry in entries {
-            let ((cleaned_entry_path, file_path), (index_key, index_value)) = entry?;
+            let ((cleaned_entry_path, file_path), (index_key, index_value)) =
+                entry.expect("no join error")?;
 
             if let Some(previous) = cas_paths.insert(cleaned_entry_path, file_path) {
                 tracing::warn!(?previous, "Duplication detected. Old entry has been ejected");