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

Method readFull

protocol/decode.go:179–183  ·  view source on GitHub ↗
(b []byte)

Source from the content-addressed store, hash-verified

177}
178
179func (d *decoder) readFull(b []byte) bool {
180 n, err := io.ReadFull(d, b)
181 d.setError(err)
182 return n == len(b)
183}
184
185func (d *decoder) readByte() byte {
186 if d.readFull(d.buffer[:1]) {

Callers 6

readByteMethod · 0.95
readInt8Method · 0.95
readInt16Method · 0.95
readInt32Method · 0.95
readInt64Method · 0.95
readFloat64Method · 0.95

Calls 1

setErrorMethod · 0.95

Tested by

no test coverage detected