Mirrors/miller
1
0
Fork 0
mirror of https://github.com/johnkerl/miller.git synced 2026-01-23 02:14:13 +00:00
Code Issues Projects Releases Wiki Activity

iterating

Browse source
This commit is contained in:
John Kerl 2025-03-09 14:48:08 -04:00
parent e47119bc2d
commit 55740c471c
1 changed files with 3 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

7
pkg/input/record_reader_xtab.go
View file

@ -231,7 +231,7 @@ func channelizedStanzaScanner(
// TODO: comment copiously we're trying to handle slow/fast/short/long reads: tail -f, smallfile, bigfile.
func (reader *RecordReaderXTAB) getRecordBatch(
stanzasChannel chan<- *types.List[*tStanza],
stanzasChannel <-chan *types.List[*tStanza],
context *types.Context,
errorChannel chan error,
) (
@ -247,9 +247,8 @@ func (reader *RecordReaderXTAB) getRecordBatch(
for _, stanza := range stanzas.Items {
if stanza.commentLines.Len() > 0 {
for f := stanza.commentLines.Front(); f != nil; f = f.Next() {
line := f.Value.(string)
recordsAndContexts.PushBack(types.NewOutputString(line+reader.readerOptions.IFS, context))
for _, commentLine := range stanza.commentLines.Items {
recordsAndContexts.PushBack(types.NewOutputString(commentLine+reader.readerOptions.IFS, context))
}
}