Skip to content

Commit 91bab5e

Browse files
authored
chore(metastore): Fix stream read condition (#16631)
1 parent 31d8648 commit 91bab5e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

‎pkg/dataobj/metastore/object.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -276,7 +276,7 @@ func forEachStream(ctx context.Context, object *dataobj.Object, predicate dataob
276276
}
277277
for {
278278
num, err := reader.Read(ctx, streams)
279-
if err != io.EOF {
279+
if err != nil && err != io.EOF {
280280
return err
281281
}
282282
if num == 0 && err == io.EOF {

0 commit comments

Comments
 (0)