Function newInputStats

input/inpututils/compressedstream.go:116–120

()

}

func newInputStats() *inputStats {
	s := new(inputStats)
	s.beginTime = time.Now()
	return s
}

func (s *inputStats) NewStatsReader(r io.ReadCloser, sz int64) io.ReadCloser {
	return &inputStatsReader{s: s, r: r, sz: sz}