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

Method leave

conn.go:1339–1341  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

1337}
1338
1339func (c *Conn) leave() {
1340 atomic.AddInt32(&c.inflight, -1)
1341}
1342
1343func (c *Conn) concurrency() int {
1344 return int(atomic.LoadInt32(&c.inflight))

Callers 2

doRequestMethod · 0.95
waitResponseMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected