jjui/internal/parser/log_parser.go

package parser

import (
	"io"
)

// ParseRows reads all rows from the provided reader and returns them as a
// slice. It is used for `jj log` and `jj evolog` commands
func ParseRows(reader io.Reader) []Row {
	var rows []Row
	controlChan := make(chan ControlMsg)
	defer close(controlChan)
	streamerChannel := ParseRowsStreaming(reader, controlChan, 50, nil)
	for {
		controlChan <- RequestMore
		chunk := <-streamerChannel
		rows = append(rows, chunk.Rows...)
		if !chunk.HasMore {
			break
		}
	}
	return rows
}