Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/segmentio/kafka-go
/ skipResponseSizeAndID
Method
skipResponseSizeAndID
conn.go:1315–1317 ·
view source on GitHub ↗
()
Source
from the content-addressed store, hash-verified
1313
}
1314
1315
func
(c *Conn) skipResponseSizeAndID() {
1316
c.rbuf.Discard(8)
1317
}
1318
1319
func
(c *Conn) readDeadline() time.Time {
1320
return
c.rdeadline.deadline()
Callers
1
waitResponse
Method · 0.95
Calls
1
Discard
Method · 0.65
Tested by
no test coverage detected