Method wrapReader

downloader/task.go:196–208

(ctx context.Context, r io.ReadCloser)

}

func (t *singleObjectTask) wrapReader(ctx context.Context, r io.ReadCloser) io.ReadCloser {
	// Create a custom reader to monitor progress every time we read from response body stream.
	r = &progressReader{
		r: r,
		reporter: func(n int64) {
			t.currentSize.Add(n)
			nl.OnProgress(t.job.Notif())
		},
	}
	// Wrap around throttler reader (noop if throttling is disabled).
	r = t.job.throttler().wrapReader(ctx, r)
	return r
}

func (t *singleObjectTask) setTotalSize(size int64) {
	if size > 0 {