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

Method discardBytes

message_reader.go:341–344  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

339}
340
341func (r *messageSetReader) discardBytes() (err error) {
342 r.remain, err = discardBytes(r.reader, r.remain)
343 return
344}
345
346func (r *messageSetReader) discardN(sz int) (err error) {
347 r.remain, err = discardN(r.reader, r.remain, sz)

Callers 1

readMessageV1Method · 0.95

Calls 1

discardBytesFunction · 0.85

Tested by

no test coverage detected