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

Method peekResponseSizeAndID

conn.go:1306–1313  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

1304}
1305
1306func (c *Conn) peekResponseSizeAndID() (int32, int32, error) {
1307 b, err := c.rbuf.Peek(8)
1308 if err != nil {
1309 return 0, 0, err
1310 }
1311 size, id := makeInt32(b[:4]), makeInt32(b[4:])
1312 return size, id, nil
1313}
1314
1315func (c *Conn) skipResponseSizeAndID() {
1316 c.rbuf.Discard(8)

Callers 1

waitResponseMethod · 0.95

Calls 2

makeInt32Function · 0.85
PeekMethod · 0.65

Tested by

no test coverage detected