diff --git a/common/net/transport.go b/common/net/transport.go index 5f334eff2..d6cc80fb0 100644 --- a/common/net/transport.go +++ b/common/net/transport.go @@ -34,9 +34,9 @@ func ReaderToChan(stream chan<- *alloc.Buffer, reader io.Reader) error { func ChanToWriter(writer io.Writer, stream <-chan *alloc.Buffer) error { for buffer := range stream { nBytes, err := writer.Write(buffer.Value) - if nBytes < buffer.Len() { - _, err = writer.Write(buffer.Value[nBytes:]) - } + if nBytes < buffer.Len() { + _, err = writer.Write(buffer.Value[nBytes:]) + } buffer.Release() if err != nil { return err