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

Function readBytes

read.go:122–127  ·  view source on GitHub ↗
(r *bufio.Reader, sz int, v *[]byte)

Source from the content-addressed store, hash-verified

120}
121
122func readBytes(r *bufio.Reader, sz int, v *[]byte) (int, error) {
123 return readBytesWith(r, sz, func(r *bufio.Reader, sz int, n int) (remain int, err error) {
124 *v, remain, err = readNewBytes(r, sz, n)
125 return
126 })
127}
128
129func readBytesWith(r *bufio.Reader, sz int, cb func(*bufio.Reader, int, int) (int, error)) (int, error) {
130 var err error

Callers 9

readFromMethod · 0.85
readFromMethod · 0.85
decodeMemberMetadataFunction · 0.85
decodeMemberAssignmentsFunction · 0.85
readFromMethod · 0.85
readFromMethod · 0.85
readFunction · 0.85
readFromMethod · 0.85
readFromMethod · 0.85

Calls 2

readBytesWithFunction · 0.85
readNewBytesFunction · 0.85

Tested by

no test coverage detected