Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-22 16:26:31 +03:00
Code Issues Packages Projects Releases Wiki Activity

remove arc

Browse Source
This commit is contained in:
dignifiedquire
2023-07-25 16:22:25 +02:00
parent e3f75f9f70
commit b9e1e50826
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/imex/transfer.rs
View File

@@ -474,10 +474,10 @@ async fn transfer_from_provider(context: &Context, ticket: &Ticket) -> Result<()
let progress = ProgressEmitter::new(0, ReceiveProgress::max_blob_progress()); let progress = ProgressEmitter::new(0, ReceiveProgress::max_blob_progress());
spawn_progress_proxy(context.clone(), progress.subscribe()); spawn_progress_proxy(context.clone(), progress.subscribe());
let jobs = Arc::new(Mutex::new(JoinSet::default())); let jobs = Mutex::new(JoinSet::default());
// Perform the transfer. // 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; let mut jobs = jobs.lock().await;
while let Some(job) = jobs.join_next().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( async fn run_get_request(
context: &Context, context: &Context,
progress: &ProgressEmitter, progress: &ProgressEmitter,
jobs: Arc<Mutex<JoinSet<()>>>, jobs: &Mutex<JoinSet<()>>,
ticket: Ticket, ticket: Ticket,
) -> anyhow::Result<Stats> { ) -> anyhow::Result<Stats> {
// DERP usage for NAT traversal and relay are currently disabled. // DERP usage for NAT traversal and relay are currently disabled.
@@ -559,7 +559,7 @@ async fn run_get_request(
async fn on_blob( async fn on_blob(
context: &Context, context: &Context,
rt: &runtime::Handle, rt: &runtime::Handle,
jobs: &Arc<Mutex<JoinSet<()>>>, jobs: &Mutex<JoinSet<()>>,
ticket: &Ticket, ticket: &Ticket,
state: fsm::AtBlobHeader, state: fsm::AtBlobHeader,
name: &str, name: &str,