style(core): rustfmt cancel and output_sink test changes

This commit is contained in:
2026-07-12 19:03:31 +02:00
parent 2e6d1fa48e
commit c348aa1c09
2 changed files with 10 additions and 2 deletions

View File

@@ -497,7 +497,11 @@ impl CoreInner {
RuntimeStatus { RuntimeStatus {
endpoint_id: self.endpoint.id().to_string(), endpoint_id: self.endpoint.id().to_string(),
addr: format!("{:?}", self.endpoint.addr()), addr: format!("{:?}", self.endpoint.addr()),
active_transfers: self.active_transfers.lock().expect("active_transfers").len() as u64, active_transfers: self
.active_transfers
.lock()
.expect("active_transfers")
.len() as u64,
active_shares: self.active_shares.lock().await.len() as u64, active_shares: self.active_shares.lock().await.len() as u64,
} }
} }

View File

@@ -83,7 +83,11 @@ fn cancellation_during_export_aborts_open_sink_file() {
let sink_for_worker = output_sink.clone(); let sink_for_worker = output_sink.clone();
let ticket = share.ticket.clone(); let ticket = share.ticket.clone();
let worker = std::thread::spawn(move || { let worker = std::thread::spawn(move || {
receiver_core.receive_with_output_sink(ticket, sink_for_worker, Some("receiver".to_string())) receiver_core.receive_with_output_sink(
ticket,
sink_for_worker,
Some("receiver".to_string()),
)
}); });
let request = wait_for_receiver_request(&sender.core, share.transfer_id); let request = wait_for_receiver_request(&sender.core, share.transfer_id);