refactor: rename num_channels to concurrent_downloads

Author: rami3l

src/cli/rustup_mode.rs

@@ -802,14 +802,14 @@ async fn check_updates(cfg: &Cfg<'_>, opts: CheckOpts) -> Result<utils::ExitCode
     let mut update_available = false;
     let channels = cfg.list_channels()?;
     let channels_len = channels.len();
-    let num_channels = cfg.process.concurrent_downloads().unwrap_or(channels_len);
+    let concurrent_downloads = cfg.process.concurrent_downloads().unwrap_or(channels_len);
 
     // Ensure that `.buffered()` is never called with 0 as this will cause a hang.
     // See: https://github.com/rust-lang/futures-rs/pull/1194#discussion_r209501774
     if channels_len > 0 {
         let multi_progress_bars =
             MultiProgress::with_draw_target(cfg.process.progress_draw_target());
-        let semaphore = Arc::new(Semaphore::new(num_channels));
+        let semaphore = Arc::new(Semaphore::new(concurrent_downloads));
         let channels = tokio_stream::iter(channels.into_iter()).map(|(name, distributable)| {
             let pb = multi_progress_bars.add(ProgressBar::new(1));
             pb.set_style(
@@ -878,7 +878,10 @@ async fn check_updates(cfg: &Cfg<'_>, opts: CheckOpts) -> Result<utils::ExitCode
                 .collect::<Vec<_>>()
                 .await
         } else {
-            channels.buffered(num_channels).collect::<Vec<_>>().await
+            channels
+                .buffered(concurrent_downloads)
+                .collect::<Vec<_>>()
+                .await
         };
 
         let t = cfg.process.stdout().terminal(cfg.process);

src/dist/manifestation.rs

@@ -157,7 +157,7 @@ impl Manifestation {
         let mut things_downloaded: Vec<String> = Vec::new();
         let components = update.components_urls_and_hashes(new_manifest)?;
         let components_len = components.len();
-        let num_channels = download_cfg
+        let concurrent_downloads = download_cfg
             .process
             .concurrent_downloads()
             .unwrap_or(components_len);
@@ -180,7 +180,7 @@ impl Manifestation {
             ));
         }
 
-        let semaphore = Arc::new(Semaphore::new(num_channels));
+        let semaphore = Arc::new(Semaphore::new(concurrent_downloads));
         let component_stream =
             tokio_stream::iter(components.into_iter()).map(|(component, format, url, hash)| {
                 let sem = semaphore.clone();