diff options
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 |