diff --git a/src/main.rs b/src/main.rs index b2896de..02c7d96 100644 --- a/src/main.rs +++ b/src/main.rs @@ -6,6 +6,7 @@ use rbx_dom_weak::types::Ref; type AssetID=u64; type AssetIDFileMap=Vec<(AssetID,std::path::PathBuf)>; +const CONCURRENT_DECODE:usize=8; const CONCURRENT_REQUESTS:usize=32; #[derive(Parser)] @@ -805,7 +806,7 @@ async fn decompile_history_into_git(config:DecompileHistoryConfig)->AResult<()>{ Ok::<_,anyhow::Error>((asset_version,contents)) }) }) - .buffered(CONCURRENT_REQUESTS) + .buffered(CONCURRENT_DECODE) .for_each(|join_handle_result|async{ match write_commit(WriteCommitConfig{ git_committer_name:config.git_committer_name.clone(), @@ -857,7 +858,7 @@ async fn download_and_decompile_history_into_git(config:DownloadAndDecompileHist Ok::<_,anyhow::Error>((asset_version,contents)) }) }) - .buffered(CONCURRENT_REQUESTS) + .buffered(CONCURRENT_DECODE) .for_each(|join_handle_result|async{ match write_commit(WriteCommitConfig{ git_committer_name:config.git_committer_name.clone(),