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

Method readBytes

protocol/decode.go:255–261  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

253}
254
255func (d *decoder) readBytes() []byte {
256 if n := d.readInt32(); n < 0 {
257 return nil
258 } else {
259 return d.read(int(n))
260 }
261}
262
263func (d *decoder) readVarBytes() []byte {
264 if n := d.readVarInt(); n < 0 {

Callers 1

decodeBytesMethod · 0.95

Calls 2

readInt32Method · 0.95
readMethod · 0.95

Tested by

no test coverage detected