MCPcopy
hub / github.com/segmentio/kafka-go / close

Method close

transport.go:1250–1252  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

1248}
1249
1250func (c *conn) close() {
1251 c.once.Do(func() { close(c.reqs) })
1252}
1253
1254func (c *conn) run(pc *protocol.Conn, reqs <-chan connRequest) {
1255 defer pc.Close()

Callers 3

grabConnOrConnectMethod · 0.95
closeIdleConnsMethod · 0.45
releaseConnMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected