diff --git a/src/download/jpmaqsdownload.rs b/src/download/jpmaqsdownload.rs index 77d6bff..c837597 100644 --- a/src/download/jpmaqsdownload.rs +++ b/src/download/jpmaqsdownload.rs @@ -129,7 +129,7 @@ impl JPMaQSDownload { // .map(|tsv| JPMaQSIndicator::new(tsv)) // .collect::, Box>>()?; let indicators: Vec<_> = dqts_vec - .par_iter() + .into_par_iter() // Use into_par_iter() to parallelize and consume dqts_vec .flat_map(|dqts| { dqts.get_timeseries_by_ticker() .into_par_iter() diff --git a/src/download/requester.rs b/src/download/requester.rs index 9dbfe62..a41a8bd 100644 --- a/src/download/requester.rs +++ b/src/download/requester.rs @@ -18,7 +18,7 @@ const TIMESERIES_ENDPOINT: &str = "/expressions/time-series"; const CATALOGUE_ENDPOINT: &str = "/group/instruments"; const API_DELAY_MILLIS: u64 = 200; -const MAX_THREAD_WORKERS: usize = 20; +const MAX_THREAD_WORKERS: usize = 100; // const JPMAQS_CATALOGUE_GROUP: &str = "JPMAQS"; #[derive(Debug, Clone)]