From 6dd05b13eed8f9f124d12812a1561fa85a575bc4 Mon Sep 17 00:00:00 2001 From: tv Date: Mon, 19 Oct 2026 23:56:52 +0200 Subject: cargo fmt --- src/sync.rs | 19 +++++++++++++------ 1 file changed, 13 insertions(+), 6 deletions(-) (limited to 'src/sync.rs') diff --git a/src/sync.rs b/src/sync.rs index 199f9fb..d9f629e 100644 --- a/src/sync.rs +++ b/src/sync.rs @@ -111,7 +111,10 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str, retry_delivery: bool peer_state.needs_generate = false; let epoch = replica.epoch; let sync_doc = replica.doc.sync(); - (epoch, sync_doc.generate_sync_message(&mut peer_state.sync_state)) + ( + epoch, + sync_doc.generate_sync_message(&mut peer_state.sync_state), + ) }; let Some(message) = message else { return Ok(None); @@ -287,11 +290,15 @@ pub(crate) async fn handle_sync( Ok(Some( check_caught_up - && peer_state.sync_state.their_heads.as_ref().is_some_and(|heads| { - heads - .iter() - .all(|h| replica.doc.get_change_by_hash(h).is_some()) - }), + && peer_state + .sync_state + .their_heads + .as_ref() + .is_some_and(|heads| { + heads + .iter() + .all(|h| replica.doc.get_change_by_hash(h).is_some()) + }), )) }) .await -- cgit v1.3.1