We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 12008ad commit 718b27cCopy full SHA for 718b27c
1 file changed
libsql-replication/src/replicator.rs
@@ -328,6 +328,10 @@ where
328
async fn inject_frame(&mut self, frame: RpcFrame) -> Result<(), Error> {
329
self.frames_synced += 1;
330
331
+ if let Some(frame_no) = frame.durable_frame_no {
332
+ self.injector.durable_frame_no(frame_no);
333
+ }
334
+
335
match self.injector.inject_frame(frame).await? {
336
Some(commit_fno) => {
337
self.client.commit_frame_no(commit_fno).await?;
0 commit comments