(orig io.ReadCloser)
| 524 | } |
| 525 | |
| 526 | func newSampler(orig io.ReadCloser) *sampler { |
| 527 | return &sampler{ |
| 528 | orig: orig, |
| 529 | errs: make(chan error, 1), |
| 530 | data: make([]byte, PayloadLimitBytes), |
| 531 | } |
| 532 | } |
| 533 | |
| 534 | func (s *sampler) setError(err error) { |
| 535 | if errors.Is(err, io.EOF) { |
no outgoing calls
no test coverage detected