Struct optimizedRecordReader

protocol/record_batch.go:113–118

optimizedRecordReader is an implementation of a RecordReader which exposes a sequence.

// optimizedRecordReader is an implementation of a RecordReader which exposes a
// sequence.
type optimizedRecordReader struct {
	records []optimizedRecord
	index   int
	buffer  Record
	headers [][]Header
}

func (r *optimizedRecordReader) ReadRecord() (*Record, error) {
	if i := r.index; i >= 0 && i < len(r.records) {