proxyreader

Documentation

Index

• type ByIncrementer
• type ProxyReader
  • func NewProxyReader(inc ByIncrementer, r io.Reader) *ProxyReader
  • func (pr *ProxyReader) Read(buf []byte) (int, error)
  • func (pr *ProxyReader) ReadAt(p []byte, offset int64) (int, error)

Types

type ByIncrementer

type ByIncrementer interface {
	ReportIncrement(int) error
}

type ProxyReader

type ProxyReader struct {
	// contains filtered or unexported fields
}

ProxyReader wraps around a reader and calls the incrementer function on every read reporting the number of bytes read

func NewProxyReader

func NewProxyReader(inc ByIncrementer, r io.Reader) *ProxyReader

func (*ProxyReader) Read

func (pr *ProxyReader) Read(buf []byte) (int, error)

func (*ProxyReader) ReadAt

func (pr *ProxyReader) ReadAt(p []byte, offset int64) (int, error)

ReadAt reads into buffer starting at offset and reports progress Calls complete method on EOF