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

Method readNewBytes

message_reader.go:495–498  ·  view source on GitHub ↗
(len int)

Source from the content-addressed store, hash-verified

493}
494
495func (r *messageSetReader) readNewBytes(len int) (res []byte, err error) {
496 res, r.remain, err = readNewBytes(r.reader, r.remain, len)
497 return
498}
499
500func (r *messageSetReader) readNewString(len int) (res string, err error) {
501 res, r.remain, err = readNewString(r.reader, r.remain, len)

Callers 1

readMessageHeaderMethod · 0.95

Calls 1

readNewBytesFunction · 0.85

Tested by

no test coverage detected