diff options
| author | tv <tv@krebsco.de> | 2026-10-31 18:38:43 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-31 18:38:43 +0100 |
| commit | a65c491cfc1b0fea8860ad64ab29a6ee8ad0faef (patch) | |
| tree | eb5a4b4284ea448a3e3a64fc6824376510a24d40 /src/swarm/sync.rs | |
| parent | 4a9f4507f3161791f80c8c25a6f0e9ccd3649c2c (diff) | |
move SyncSession to document
Diffstat (limited to 'src/swarm/sync.rs')
| -rw-r--r-- | src/swarm/sync.rs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs index 3cbe5f3..35bc4c7 100644 --- a/src/swarm/sync.rs +++ b/src/swarm/sync.rs @@ -355,7 +355,7 @@ pub(crate) async fn handle_sync( // to another epoch. tokio::task::spawn_blocking(move || -> Result<Option<(bool, bool)>> { // Before the lock: decoding a large message takes a while. - let message = crate::state::decode_sync(&message)?; + let message = crate::document::sync::decode(&message)?; let mut replica = doc.blocking_write(); // Authoritative check, under the same lock as the apply: the document may |
