package mpb

import (
	"io"
	"time"
)

type proxyReader struct {
	io.ReadCloser
	bar *Bar
	iT  time.Time
}

func (prox *proxyReader) Read(p []byte) (int, error) {
	n, err := prox.ReadCloser.Read(p)
	if n > 0 {
		prox.bar.IncrBy(n)
		prox.bar.DecoratorEwmaUpdate(time.Since(prox.iT))
		prox.iT = time.Now()
	}
	if err == io.EOF {
		go prox.bar.SetTotal(0, true)
	}
	return n, err
}

type proxyWriterTo struct {
	*proxyReader
	wt io.WriterTo
}

func (prox *proxyWriterTo) WriteTo(w io.Writer) (int64, error) {
	n, err := prox.wt.WriteTo(w)
	if n > 0 {
		prox.bar.IncrInt64(n)
		prox.bar.DecoratorEwmaUpdate(time.Since(prox.iT))
		prox.iT = time.Now()
	}
	if err == io.EOF {
		go prox.bar.SetTotal(0, true)
	}
	return n, err
}