csv_reader.go

type CSVParser struct {
       scanner *bufio.Scanner
       Validator func([]string) bool
       Output chan []string
}

func ReaderCSVParser(reader io.Reader) *CSVParser {
       return &CSVParser{
               bufio.NewScanner(reader),
               ValidateCSVLine,
               make(chan []string),
       }
}

func (c *CSVParser) Parse (dest chan []string){
       for c.scanner.Scan() {
               line := strings.Split(c.scanner.Text(), ",")
               valid := c.Validator(line)
               if !valid {
                       continue
               }
               c.Output <- line
       }
}