Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
1250
func
(c *conn) close() {
1251
c.once.Do(
func
() { close(c.reqs) })
1252
}
1253
1254
func
(c *conn) run(pc *protocol.Conn, reqs <-
chan
connRequest) {
1255
defer
pc.Close()
Callers
3
grabConnOrConnect
Method · 0.95
closeIdleConns
Method · 0.45
releaseConn
Method · 0.45
Calls
no outgoing calls
Tested by
no test coverage detected