Skip to content

Commit

Permalink
more reader
Browse files Browse the repository at this point in the history
  • Loading branch information
BrennaEpp committed Dec 20, 2021
1 parent 5681f01 commit 6b9509e
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions storage/reader.go
Expand Up @@ -483,7 +483,7 @@ func (o *ObjectHandle) newRangeReaderWithGRPC(ctx context.Context, offset, lengt
var msg *storagepb.ReadObjectResponse
var err error

err = runWithRetry(cc, func() error {
err = run(cc, func() error {
stream, err = o.c.gc.ReadObject(cc, req)
if err != nil {
return err
Expand All @@ -492,7 +492,7 @@ func (o *ObjectHandle) newRangeReaderWithGRPC(ctx context.Context, offset, lengt
msg, err = stream.Recv()

return err
})
}, o.retry, true)
if err != nil {
// Close the stream context we just created to ensure we don't leak
// resources.
Expand Down

0 comments on commit 6b9509e

Please sign in to comment.