()
| 134 | } |
| 135 | |
| 136 | func (s *TCP) Stats() baker.InputStats { |
| 137 | return baker.InputStats{ |
| 138 | NumProcessedLines: atomic.LoadInt64(&s.numLines), |
| 139 | } |
| 140 | } |
| 141 | |
| 142 | func (s *TCP) Stop() { |
| 143 | atomic.StoreInt64(&s.stop, 1) |
nothing calls this directly
no outgoing calls
no test coverage detected