X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/1a0a58c4f22af82e0a37440af3b0948771bca5e1..3e4f591181a38d739d94cf9321f874c19937d199:/sdk/go/streamer/transfer.go?ds=inline diff --git a/sdk/go/streamer/transfer.go b/sdk/go/streamer/transfer.go index a4a194f69b..3f5f9344c5 100644 --- a/sdk/go/streamer/transfer.go +++ b/sdk/go/streamer/transfer.go @@ -249,9 +249,7 @@ func (this *AsyncStream) transfer(source_reader io.Reader) { } } } else { - if reader_status == io.EOF { - // no more reads expected, so this is ok - } else { + if reader_status == nil { // slices channel closed without signaling EOF reader_status = io.ErrUnexpectedEOF }