From 1d646344e64eb9f821f2b0f080672c685ac154a9 Mon Sep 17 00:00:00 2001
From: "K. Isom" <kyle@imap.cc>
Date: Sun, 18 Oct 2026 03:28:51 -0700
Subject: [PATCH] style: cargo fmt --all

---
 tines-core/src/exchange.rs | 34 +++++++++++++++++++++-------------
 tines-core/tests/pair.rs   |  7 +++++--
 2 files changed, 26 insertions(+), 15 deletions(-)

diff --git a/tines-core/src/exchange.rs b/tines-core/src/exchange.rs
index db7da53..7687ba0 100644
--- a/tines-core/src/exchange.rs
+++ b/tines-core/src/exchange.rs
@@ -402,11 +402,7 @@ fn select_addressed<S: Store, A: PartialEq>(
 /// Returns `true` when `(id, addr)` has been recorded in the bounce table —
 /// i.e. `id` was received from, or forwarded to, `addr`. A message addressed to
 /// such a peer would just bounce back, so it is skipped.
-fn is_sourced<A: PartialEq>(
-    bounce: &[(ObservationId, A)],
-    id: ObservationId,
-    addr: &A,
-) -> bool {
+fn is_sourced<A: PartialEq>(bounce: &[(ObservationId, A)], id: ObservationId, addr: &A) -> bool {
     for &(bid, ref baddr) in bounce {
         if bid == id && baddr == addr {
             return true;
@@ -929,13 +925,20 @@ mod tests {
         o.to = Some(ME);
         o.lifetime_ms = Some(100);
         o.age_ms = 200;
-        let frame = Frame::Obs { from: [2; 16], obs: o.clone() };
+        let frame = Frame::Obs {
+            from: [2; 16],
+            obs: o.clone(),
+        };
         assert!(
             ex.on_event(Event::Frame(1, frame_bytes(&frame)), &mut store, 0)
                 .is_none(),
             "an expired addressed obs must not be delivered"
         );
-        assert_eq!(store.len(), 0, "an expired addressed obs must not be stored");
+        assert_eq!(
+            store.len(),
+            0,
+            "an expired addressed obs must not be stored"
+        );
     }
 
     #[test]
@@ -972,11 +975,13 @@ mod tests {
         let mut o = obs([2; 16], 7, 0, None, b"t", b"hi");
         o.to = Some(ME);
         o.lifetime_ms = None;
-        let frame = Frame::Obs { from: [2; 16], obs: o.clone() };
-        assert!(
-            ex.on_event(Event::Frame(1, frame_bytes(&frame)), &mut store, 0)
-                .is_none()
-        );
+        let frame = Frame::Obs {
+            from: [2; 16],
+            obs: o.clone(),
+        };
+        assert!(ex
+            .on_event(Event::Frame(1, frame_bytes(&frame)), &mut store, 0)
+            .is_none());
         assert_eq!(
             store.len(),
             0,
@@ -1106,7 +1111,10 @@ mod tests {
         let mut o = obs([2; 16], 7, 0, None, b"t", b"hi");
         o.to = Some([3; 16]);
         o.lifetime_ms = Some(consts::SUMMARY_INTERVAL_MS * 10);
-        let frame = Frame::Obs { from: [2; 16], obs: o };
+        let frame = Frame::Obs {
+            from: [2; 16],
+            obs: o,
+        };
         ex.on_event(Event::Frame(1, frame_bytes(&frame)), &mut store, 0);
 
         // Draining must never bounce the addressed obs back to its source (addr
diff --git a/tines-core/tests/pair.rs b/tines-core/tests/pair.rs
index 2b36290..fac87e2 100644
--- a/tines-core/tests/pair.rs
+++ b/tines-core/tests/pair.rs
@@ -226,7 +226,9 @@ fn observe_to_creates_addressed_message() {
     let (a, _b) = PairTransport::pair(1500);
     let mut node = Node::new([1u8; 16], 0, MemStore::new(), a);
 
-    let id = node.observe_to([2; 16], 5000, b"task", b"go", None, 0).unwrap();
+    let id = node
+        .observe_to([2; 16], 5000, b"task", b"go", None, 0)
+        .unwrap();
     assert_eq!(node.next_seq(), 1);
 
     let obs = node.store().get(&id, 0).expect("observation stored");
@@ -259,7 +261,8 @@ fn belief_excludes_addressed_to_others() {
     // A broadcast observation and an addressed-to-other observation on the
     // same topic. `me` = [1;16]; the addressed one is for [2;16] (≠ me).
     node.observe(b"door", b"broadcast", None, 0).unwrap();
-    node.observe_to([2; 16], 10_000, b"door", b"addressed", None, 10).unwrap();
+    node.observe_to([2; 16], 10_000, b"door", b"addressed", None, 10)
+        .unwrap();
 
     let now = 100_000u64;
     let belief = node