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

Function readArrayWith

read.go:178–193  ·  view source on GitHub ↗
(r *bufio.Reader, sz int, cb func(*bufio.Reader, int) (int, error))

Source from the content-addressed store, hash-verified

176}
177
178func readArrayWith(r *bufio.Reader, sz int, cb func(*bufio.Reader, int) (int, error)) (int, error) {
179 var err error
180 var len int32
181
182 if sz, err = readInt32(r, sz, &len); err != nil {
183 return sz, err
184 }
185
186 for n := int(len); n > 0; n-- {
187 if sz, err = cb(r, sz); err != nil {
188 break
189 }
190 }
191
192 return sz, err
193}
194
195func readStringArray(r *bufio.Reader, sz int, v *[]string) (remain int, err error) {
196 var content []string

Callers 15

readFromMethod · 0.85
decodeMemberMetadataFunction · 0.85
decodeMemberAssignmentsFunction · 0.85
readInt32ArrayFunction · 0.85
readOffsetMethod · 0.85
readFromMethod · 0.85
readFromMethod · 0.85
readFromMethod · 0.85
readFromMethod · 0.85
readFromMethod · 0.85
readStringArrayFunction · 0.85

Calls 1

readInt32Function · 0.70

Tested by

no test coverage detected