(r io.ReadCloser, sz int64)
| 120 | } |
| 121 | |
| 122 | func (s *inputStats) NewStatsReader(r io.ReadCloser, sz int64) io.ReadCloser { |
| 123 | return &inputStatsReader{s: s, r: r, sz: sz} |
| 124 | } |
| 125 | |
| 126 | func (s *inputStats) NewFile(sz int64) { |
| 127 | atomic.AddInt64(&s.totalFiles, 1) |