Skip to content

Commit 6180197

Browse files
Update disk-buffering/src/main/java/io/opentelemetry/contrib/disk/buffering/internal/storage/files/reader/DelimitedProtoStreamReader.java
Co-authored-by: jason plumb <[email protected]>
1 parent a71cf30 commit 6180197

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

disk-buffering/src/main/java/io/opentelemetry/contrib/disk/buffering/internal/storage/files/reader/DelimitedProtoStreamReader.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ public byte[] readNext() throws IOException {
2525
return null;
2626
}
2727
byte[] bytes = new byte[itemSize];
28-
if (inputStream.read(bytes) < 0) {
28+
if (inputStream.read(bytes) <= 0) {
2929
return null;
3030
}
3131
return bytes;

0 commit comments

Comments
 (0)