2798: Renamed TransferBuffer->AsyncStream, BufferReader->StreamReader,

[arvados.git] / sdk / go / src / arvados.org / streamer / transfer.go

diff --git a/sdk/go/src/arvados.org/streamer/transfer.go b/sdk/go/src/arvados.org/streamer/transfer.go
index b017dbf277c855e949f0eab7780facf451625318..ab8f941af77760620dcf25e7bd6cacb09e1dd1f3 100644 (file)
--- a/sdk/go/src/arvados.org/streamer/transfer.go
+++ b/sdk/go/src/arvados.org/streamer/transfer.go
@@ -27,13 +27,13 @@ type readResult struct {
 // Supports writing into a buffer
 type bufferWriter struct {
        buf []byte
-       ptr *int
+       ptr int
 }
 
 // Copy p into this.buf, increment pointer and return number of bytes read.
-func (this bufferWriter) Write(p []byte) (n int, err error) {
-       n = copy(this.buf[*this.ptr:], p)
-       *this.ptr += n
+func (this *bufferWriter) Write(p []byte) (n int, err error) {
+       n = copy(this.buf[this.ptr:], p)
+       this.ptr += n
        return n, nil
 }
 
@@ -44,7 +44,7 @@ func readIntoBuffer(buffer []byte, r io.Reader, slices chan<- readerSlice) {
        defer close(slices)
 
        if writeto, ok := r.(io.WriterTo); ok {
-               n, err := writeto.WriteTo(bufferWriter{buffer, new(int)})
+               n, err := writeto.WriteTo(&bufferWriter{buffer, 0})
                if err != nil {
                        slices <- readerSlice{nil, err}
                } else {