From b9e1e508260586b36b15a32b9139c44501a91770 Mon Sep 17 00:00:00 2001
From: dignifiedquire <me@dignifiedquire.com>
Date: Tue, 25 Jul 2023 16:22:25 +0200
Subject: [PATCH] remove arc

---
 src/imex/transfer.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/imex/transfer.rs b/src/imex/transfer.rs
index 6c2662897..bc2b1570e 100644
--- a/src/imex/transfer.rs
+++ b/src/imex/transfer.rs
@@ -474,10 +474,10 @@ async fn transfer_from_provider(context: &Context, ticket: &Ticket) -> Result<()
     let progress = ProgressEmitter::new(0, ReceiveProgress::max_blob_progress());
     spawn_progress_proxy(context.clone(), progress.subscribe());
 
-    let jobs = Arc::new(Mutex::new(JoinSet::default()));
+    let jobs = Mutex::new(JoinSet::default());
 
     // Perform the transfer.
-    let stats = run_get_request(context, &progress, jobs.clone(), ticket.clone()).await?;
+    let stats = run_get_request(context, &progress, &jobs, ticket.clone()).await?;
 
     let mut jobs = jobs.lock().await;
     while let Some(job) = jobs.join_next().await {
@@ -496,7 +496,7 @@ async fn transfer_from_provider(context: &Context, ticket: &Ticket) -> Result<()
 async fn run_get_request(
     context: &Context,
     progress: &ProgressEmitter,
-    jobs: Arc<Mutex<JoinSet<()>>>,
+    jobs: &Mutex<JoinSet<()>>,
     ticket: Ticket,
 ) -> anyhow::Result<Stats> {
     // DERP usage for NAT traversal and relay are currently disabled.
@@ -559,7 +559,7 @@ async fn run_get_request(
 async fn on_blob(
     context: &Context,
     rt: &runtime::Handle,
-    jobs: &Arc<Mutex<JoinSet<()>>>,
+    jobs: &Mutex<JoinSet<()>>,
     ticket: &Ticket,
     state: fsm::AtBlobHeader,
     name: &str,