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

Method decodeArray

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

Source from the content-addressed store, hash-verified

107}
108
109func (d *decoder) decodeArray(v value, elemType reflect.Type, decodeElem decodeFunc) {
110 if n := d.readInt32(); n < 0 {
111 v.setArray(array{})
112 } else {
113 a := makeArray(elemType, int(n))
114 for i := 0; i < int(n) && d.remain > 0; i++ {
115 decodeElem(d, a.index(i))
116 }
117 v.setArray(a)
118 }
119}
120
121func (d *decoder) decodeCompactArray(v value, elemType reflect.Type, decodeElem decodeFunc) {
122 if n := d.readUnsignedVarInt(); n < 1 {

Callers 1

arrayDecodeFuncOfFunction · 0.80

Calls 4

readInt32Method · 0.95
makeArrayFunction · 0.70
setArrayMethod · 0.45
indexMethod · 0.45

Tested by

no test coverage detected