()
| 240 | } |
| 241 | |
| 242 | func (s *CompressedInput) Stop() { |
| 243 | close(s.stopNow) |
| 244 | atomic.StoreInt64(&s.stopping, 1) |
| 245 | } |
| 246 | |
| 247 | func (s *CompressedInput) ParseFile(fn string) { |
| 248 | if strings.HasSuffix(fn, ".zst") || strings.HasSuffix(fn, ".zstd") { |
nothing calls this directly
no outgoing calls
no test coverage detected