| 1249 | } |
| 1250 | |
| 1251 | type writerRecords struct { |
| 1252 | msgs []Message |
| 1253 | index int |
| 1254 | record Record |
| 1255 | key bytesReadCloser |
| 1256 | value bytesReadCloser |
| 1257 | } |
| 1258 | |
| 1259 | func (r *writerRecords) ReadRecord() (*Record, error) { |
| 1260 | if r.index >= 0 && r.index < len(r.msgs) { |
nothing calls this directly
no outgoing calls
no test coverage detected