diff options
| author | tv <tv@krebsco.de> | 2026-11-01 22:31:49 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-01 22:31:49 +0100 |
| commit | d7433f9d34c299e7ce31542aede80d2530c1e45f (patch) | |
| tree | e6653872b6822a1b04523d8b8444b75d972ba783 /src/swarm/sync.rs | |
| parent | 3e115a7e9cc5846d6c1025a7297a006c2d64709b (diff) | |
document: introduce patch log
Diffstat (limited to 'src/swarm/sync.rs')
| -rw-r--r-- | src/swarm/sync.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs index b881609..3bfbf7d 100644 --- a/src/swarm/sync.rs +++ b/src/swarm/sync.rs @@ -389,9 +389,9 @@ pub(crate) async fn handle_sync( peer_state.reports_ready = Some(from_ready); let heads_before = replica.heads().to_vec(); - peer_state - .sync - .receive(&mut replica.doc, message) + let sync = &mut peer_state.sync; + replica + .logged(|doc, log| (sync.receive_logged(doc, message, log), true)) .context("Automerge sync failed")?; peer_state.last_sync_rx = Some(Instant::now()); if let Some(wait) = &peer_state.sync.reply { |
