()
| 93 | } |
| 94 | |
| 95 | func (m *multiRecordReader) ReadRecord() (*Record, error) { |
| 96 | for { |
| 97 | if m.index == len(m.batches) { |
| 98 | return nil, io.EOF |
| 99 | } |
| 100 | r, err := m.batches[m.index].ReadRecord() |
| 101 | if err == nil { |
| 102 | return r, nil |
| 103 | } |
| 104 | if !errors.Is(err, io.EOF) { |
| 105 | return nil, err |
| 106 | } |
| 107 | m.index++ |
| 108 | } |
| 109 | } |
| 110 | |
| 111 | // optimizedRecordReader is an implementation of a RecordReader which exposes a |
| 112 | // sequence. |
nothing calls this directly
no test coverage detected