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

Method remaining

message_reader.go:96–104  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

94}
95
96func (r *messageSetReader) remaining() (remain int) {
97 if r.empty {
98 return 0
99 }
100 for s := r.readerStack; s != nil; s = s.parent {
101 remain += s.remain
102 }
103 return
104}
105
106func (r *messageSetReader) discard() (err error) {
107 switch {

Callers 4

newReaderHelperFunction · 0.95
TestMessageSetReaderFunction · 0.80
readMessageMethod · 0.80

Calls

no outgoing calls

Tested by 3

newReaderHelperFunction · 0.76
TestMessageSetReaderFunction · 0.64