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

Method decodeCompactArray

protocol/decode.go:121–131  ·  view source on GitHub ↗
(v value, elemType reflect.Type, decodeElem decodeFunc)

Source from the content-addressed store, hash-verified

119}
120
121func (d *decoder) decodeCompactArray(v value, elemType reflect.Type, decodeElem decodeFunc) {
122 if n := d.readUnsignedVarInt(); n < 1 {
123 v.setArray(array{})
124 } else {
125 a := makeArray(elemType, int(n-1))
126 for i := 0; i < int(n-1) && d.remain > 0; i++ {
127 decodeElem(d, a.index(i))
128 }
129 v.setArray(a)
130 }
131}
132
133func (d *decoder) discardAll() {
134 d.discard(d.remain)

Callers 1

arrayDecodeFuncOfFunction · 0.80

Calls 4

readUnsignedVarIntMethod · 0.95
makeArrayFunction · 0.70
setArrayMethod · 0.45
indexMethod · 0.45

Tested by

no test coverage detected