From 38000efab281bbf4b783e8c841664f9cefe99d72 Mon Sep 17 00:00:00 2001 From: Meta Vens Date: Wed, 30 Sep 2026 17:55:30 +0200 Subject: [PATCH] cultmesh-rs: rustfmt the refusal tests Co-Authored-By: Claude Opus 5.5 --- packages/cultmesh-rs/src/lib.rs | 4 +++- packages/cultmesh-rs/tests/rudp_document_server.rs | 3 ++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/packages/cultmesh-rs/src/lib.rs b/packages/cultmesh-rs/src/lib.rs index 83b713ad..631e1c2f 100644 --- a/packages/cultmesh-rs/src/lib.rs +++ b/packages/cultmesh-rs/src/lib.rs @@ -1347,7 +1347,9 @@ mod tests { // The publisher hears the refusal and its reason, long before its flush // deadline: a refusal is not mistaken for loss. assert!( - error.to_string().contains("refused the message: injected durable sink failure"), + error + .to_string() + .contains("refused the message: injected durable sink failure"), "{error:#}" ); assert!(waited < Duration::from_secs(5), "waited {waited:?}"); diff --git a/packages/cultmesh-rs/tests/rudp_document_server.rs b/packages/cultmesh-rs/tests/rudp_document_server.rs index 45a8eb39..b30f1c14 100644 --- a/packages/cultmesh-rs/tests/rudp_document_server.rs +++ b/packages/cultmesh-rs/tests/rudp_document_server.rs @@ -624,7 +624,8 @@ fn a_restarted_client_starts_with_a_fresh_payload_budget() -> Result<()> { } #[test] -fn application_rejection_is_nonfatal_peer_scoped_refused_to_the_peer_and_unacknowledged() -> Result<()> { +fn application_rejection_is_nonfatal_peer_scoped_refused_to_the_peer_and_unacknowledged() +-> Result<()> { let clock = Clock::new(48_000); let sink = Sink::fail_once(); let source = Source::fail_once(vec![document("snapshot", vec![4, 5, 6])]);