syncprogress

type Reader ¶

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

Reader wraps an io.Reader and fires a progress callback while bytes pass through.

func NewReader(reader io.Reader, cb func(int64)) *Reader

func (p *Reader) Read(buf []byte) (int, error)