Method Stop

input/tcp.go:142–144 · view source on GitHub ↗

()

Source from the content-addressed store, hash-verified

140	}
141
142	func (s *TCP) Stop() {
143	atomic.StoreInt64(&s.stop, 1)
144	}
145
146	func (s TCP) handleStream(conn net.TCPConn) error {
147	r, err := gzip.NewReader(conn)

nothing calls this directly

no outgoing calls

no test coverage detected