(err error)
| 532 | } |
| 533 | |
| 534 | func (s *sampler) setError(err error) { |
| 535 | if errors.Is(err, io.EOF) { |
| 536 | err = nil |
| 537 | } |
| 538 | |
| 539 | select { |
| 540 | case s.errs <- err: |
| 541 | default: |
| 542 | } |
| 543 | } |
| 544 | |
| 545 | func (s *sampler) Read(b []byte) (int, error) { |
| 546 | n, err := s.orig.Read(b) |