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])]);