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

Function newMessageSetReader

message_reader.go:84–94  ·  view source on GitHub ↗
(reader *bufio.Reader, remain int)

Source from the content-addressed store, hash-verified

82}
83
84func newMessageSetReader(reader *bufio.Reader, remain int) (*messageSetReader, error) {
85 res := &messageSetReader{
86 readerStack: &readerStack{
87 reader: reader,
88 remain: remain,
89 },
90 decompressed: acquireBuffer(),
91 }
92 err := res.readHeader()
93 return res, err
94}
95
96func (r *messageSetReader) remaining() (remain int) {
97 if r.empty {

Callers 2

newReaderHelperFunction · 0.85
ReadBatchWithMethod · 0.85

Calls 2

readHeaderMethod · 0.95
acquireBufferFunction · 0.85

Tested by 1

newReaderHelperFunction · 0.68