Function NewProgressReader

daemon/internal/progress/progressreader.go:23–32

NewProgressReader creates a new ProgressReader.

(in io.ReadCloser, out Output, size int64, id, action string)

// NewProgressReader creates a new ProgressReader.
func NewProgressReader(in io.ReadCloser, out Output, size int64, id, action string) *Reader {
	return &Reader{
		in:          in,
		out:         out,
		size:        size,
		id:          id,
		action:      action,
		rateLimiter: rate.NewLimiter(rate.Every(100*time.Millisecond), 1),
	}
}

func (p *Reader) Read(buf []byte) (int, error) {
	read, err := p.in.Read(buf)