X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/ef3e45fcc338a85432c207685567385972f79ee6..b7b9ea44ada30b1251fb10c872cb1da1d7c29bd0:/sdk/go/keepclient/collectionreader.go diff --git a/sdk/go/keepclient/collectionreader.go b/sdk/go/keepclient/collectionreader.go index d2c171d961..33bb58710e 100644 --- a/sdk/go/keepclient/collectionreader.go +++ b/sdk/go/keepclient/collectionreader.go @@ -209,6 +209,10 @@ GET: } var buf = make([]byte, fs.Offset+fs.Len) _, err = io.ReadFull(rdr, buf) + errClosing := rdr.Close() + if err == nil { + err = errClosing + } if err != nil { r.err = err close(r.errNotNil) @@ -239,7 +243,7 @@ GET: // In case we exited the above loop early: before returning, // drain the toGet channel so its sender doesn't sit around // blocking forever. - for _ = range r.toGet { + for range r.toGet { } }