cultmesh-rs: rustfmt the refusal tests
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
This commit is contained in:
parent
25b075a473
commit
38000efab2
2 changed files with 5 additions and 2 deletions
|
|
@ -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:?}");
|
||||
|
|
|
|||
|
|
@ -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])]);
|
||||
|
|
|
|||
Loading…
Reference in a new issue