diff --git a/src/mirror/fjall.rs b/src/mirror/fjall.rs index c7b791d..6603204 100644 --- a/src/mirror/fjall.rs +++ b/src/mirror/fjall.rs @@ -353,6 +353,7 @@ async fn export_stream( latest_cursor } }; + cursor += 1; // make cursor exclusive Ok(ws.on_upgrade(move |mut socket| async move { loop {