From c348aa1c099e2bb92e749cac1da78f81cadf4c15 Mon Sep 17 00:00:00 2001
From: Hammed Abass <abasshammedola@gmail.com>
Date: Sun, 12 Jul 2026 19:03:31 +0200
Subject: [PATCH] style(core): rustfmt cancel and output_sink test changes

---
 crates/vnidrop/src/runtime.rs       | 6 +++++-
 crates/vnidrop/tests/output_sink.rs | 6 +++++-
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/crates/vnidrop/src/runtime.rs b/crates/vnidrop/src/runtime.rs
index e5b7953..d24b131 100644
--- a/crates/vnidrop/src/runtime.rs
+++ b/crates/vnidrop/src/runtime.rs
@@ -497,7 +497,11 @@ impl CoreInner {
         RuntimeStatus {
             endpoint_id: self.endpoint.id().to_string(),
             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,
         }
     }
diff --git a/crates/vnidrop/tests/output_sink.rs b/crates/vnidrop/tests/output_sink.rs
index 79db032..1b01319 100644
--- a/crates/vnidrop/tests/output_sink.rs
+++ b/crates/vnidrop/tests/output_sink.rs
@@ -83,7 +83,11 @@ fn cancellation_during_export_aborts_open_sink_file() {
     let sink_for_worker = output_sink.clone();
     let ticket = share.ticket.clone();
     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);