We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c9d8a2d commit 903c881Copy full SHA for 903c881
libsql-wal/src/replication/replicator.rs
@@ -82,7 +82,7 @@ impl<IO: Io> Replicator<IO> {
82
let replicated_until = {
83
let (stream, replicated_until) = current
84
.tail()
85
- .stream_pages_from( replicated_until, self.next_frame_no, &mut seen).await;
+ .stream_pages_from(replicated_until, self.next_frame_no, &mut seen).await;
86
tokio::pin!(stream);
87
88
let mut stream = stream.peekable();
0 commit comments