mirror of
https://github.com/aljazceru/turso.git
synced 2026-01-06 01:34:21 +01:00
core/mvcc/logical-log: fix is_eof
This commit is contained in:
@@ -349,7 +349,8 @@ impl StreamingLogicalLogReader {
|
||||
}
|
||||
|
||||
pub fn is_eof(&self) -> bool {
|
||||
self.offset >= self.file_size
|
||||
// if we are positioned at the end of file and we have consumed all bytes
|
||||
self.offset >= self.file_size && self.bytes_can_read() == 0
|
||||
}
|
||||
|
||||
fn consume_u8(&mut self, io: &Arc<dyn crate::IO>) -> Result<u8> {
|
||||
|
||||
Reference in New Issue
Block a user