(size int, res interface{})
| 1293 | } |
| 1294 | |
| 1295 | func (c *Conn) readResponse(size int, res interface{}) error { |
| 1296 | size, err := read(&c.rbuf, size, res) |
| 1297 | if err != nil { |
| 1298 | var kafkaError Error |
| 1299 | if errors.As(err, &kafkaError) { |
| 1300 | size, err = discardN(&c.rbuf, size, size) |
| 1301 | } |
| 1302 | } |
| 1303 | return expectZeroSize(size, err) |
| 1304 | } |
| 1305 | |
| 1306 | func (c *Conn) peekResponseSizeAndID() (int32, int32, error) { |
| 1307 | b, err := c.rbuf.Peek(8) |
no test coverage detected