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

Struct multiRecordReader

protocol/record_batch.go:90–93  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

88}
89
90type multiRecordReader struct {
91 batches []RecordReader
92 index int
93}
94
95func (m *multiRecordReader) ReadRecord() (*Record, error) {
96 for {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected