checkout latest snapshot in continuous mode

denoland · Nov 9, 2023 · 027fed8 · 027fed8
1 parent 04bcbbd
commit 027fed8
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/denokv/main.rs b/denokv/main.rs
@@ -299,6 +299,7 @@ async fn run_sync(
   ttc.ensure_initial_snapshot_completed(&source).await?;
 
   log::info!("Initial snapshot is complete, starting sync.");
+  ttc.checkout([0xffu8; 10])?;
   drop(initial_sync_ok_tx);
 
   loop {
@@ -308,7 +309,7 @@ async fn run_sync(
       return Ok(());
     }
 
-    // In continuous mode, advance snapshot to latest version
+    // In continuous mode, always advance snapshot to latest version
     ttc.checkout([0xffu8; 10])?;
 
     let sleep_duration = std::time::Duration::from_millis(