diff options
| author | tv <tv@krebsco.de> | 2026-10-19 23:56:52 +0200 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-19 23:56:52 +0200 |
| commit | 6dd05b13eed8f9f124d12812a1561fa85a575bc4 (patch) | |
| tree | fa8406ed35f4c9800be5f7c9666e297b61cc6446 /src/sync.rs | |
| parent | 2dd4712902c63bfe393933ed165bb7481aa932ec (diff) | |
cargo fmt
Diffstat (limited to 'src/sync.rs')
| -rw-r--r-- | src/sync.rs | 19 |
1 files changed, 13 insertions, 6 deletions
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 |