Skip to content

Commit 57b765e

Browse files
committed
injector: clear buffer after flushing frames
1 parent 1bba54b commit 57b765e

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

libsql-wal/src/replication/injector.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,7 @@ impl<IO: Io> Injector<IO> {
5757
.inject_frames(buffer, commit_data, &mut self.tx)
5858
.await?;
5959
self.buffer = buffer;
60+
self.buffer.clear();
6061

6162
Ok(())
6263
}

0 commit comments

Comments
 (0)