Skip to content

Commit aad96b0

Browse files
author
Devdutt Shenoi
committed
fix: early EOF
1 parent faacd19 commit aad96b0

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/parseable/staging/reader.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -263,7 +263,7 @@ pub fn get_reverse_reader<T: Read + Seek>(
263263
messages.push((header, offset, size));
264264
offset += size;
265265
}
266-
Err(err) if err.kind() == io::ErrorKind::UnexpectedEof => break,
266+
Err(err) if err.kind() == io::ErrorKind::UnexpectedEof && messages.len() > 0 => break,
267267
Err(err) => return Err(err),
268268
}
269269
}

0 commit comments

Comments
 (0)