testRecordIter is a simple recordIter implementation for tests
| 977 | |
| 978 | // testRecordIter is a simple recordIter implementation for tests |
| 979 | type testRecordIter struct { |
| 980 | records []*kgo.Record |
| 981 | index int |
| 982 | } |
| 983 | |
| 984 | func (t *testRecordIter) Next() *kgo.Record { |
| 985 | if t.index >= len(t.records) { |
nothing calls this directly
no outgoing calls
no test coverage detected