push by default

1 files changed, 4 insertions, 5 deletions

diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs
index aea6a0b..e551cb8 100644
--- a/src/swarm/sync.rs
+++ b/src/swarm/sync.rs
@@ -138,7 +138,6 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str) -> Result<()> {
             .map(|estimate| estimate.bytes_per_sec);
         let failed = peer_state_mutex.lock().await.failed_whole(Instant::now());
         let delta_threshold = state.blobs.delta_threshold_for(rate, failed);
-        let push_changes = state.push_changes;
 
         let stats = Arc::clone(&state.stats);
         let clock = Arc::clone(&state.clock);
@@ -168,10 +167,10 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str) -> Result<()> {
                         delta_threshold,
                         Instant::now(),
                     );
-                    // Along a tree, taken as delivered: the changes as they are, if pushing
-                    // (`AppState::push_changes`). Only those too small to deflate: larger
-                    // ones go as a message, deflated (`compress`).
-                    let pushed = (push_changes && level && writer.is_some() && again.is_none())
+                    // Along a tree, taken as delivered: the changes as they are
+                    // (`SyncSession::push`). Only those too small to deflate: larger ones go
+                    // as a message, deflated (`compress`).
+                    let pushed = (level && writer.is_some() && again.is_none())
                         .then(|| {
                             peer_state.sync.push(
                                 &replica.doc,