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

Method discardN

message_reader.go:346–349  ·  view source on GitHub ↗
(sz int)

Source from the content-addressed store, hash-verified

344}
345
346func (r *messageSetReader) discardN(sz int) (err error) {
347 r.remain, err = discardN(r.reader, r.remain, sz)
348 return
349}
350
351func (r *messageSetReader) markRead() {
352 if r.count == 0 {

Callers 2

discardMethod · 0.95
readMessageV1Method · 0.95

Calls 1

discardNFunction · 0.85

Tested by

no test coverage detected