Method Run

input/inputtest/records.go:35–47

(output chan<- *baker.Data)

}

func (in *Records) Run(output chan<- *baker.Data) error {

	var buf []byte

	// Send all lines via a single baker.Data blob.
	for _, ll := range in.Records {
		buf = ll.ToText(buf)
		buf = append(buf, '\n')
	}
	output <- &baker.Data{Bytes: buf}

	return nil
}

func (Records) Stop()                           {}
func (Records) FreeMem(data *baker.Data)        {}