Function NewFileReader

main.go:331–363

(path string)

}

func NewFileReader(path string) (*FileReader, error) {
	file, err := os.Open(path)
	if err != nil {
		return nil, err
	}
	reader := FileReader{
		LineChan:    make(chan string),
		CloseSignal: make(chan struct{}),
	}
	go func() {
		defer file.Close()
		scanner := bufio.NewScanner(file)
		for scanner.Scan() {
			line := strings.TrimSpace(scanner.Text())
			if len(line) == 0 {
				continue
			}
			lr := []rune(line)
			if lr[0] == '#' || (len(lr) > 1 && lr[0] == '/' && lr[1] == '/') {
				continue
			}
			for i, r := range lr {
				if r == '#' || (r == '/' && i < len(lr)-1 && lr[i+1] == '/') {
					line = strings.TrimSpace(string(lr[:i]))
					break
				}
			}
			reader.LineChan <- line
		}
		reader.CloseSignal <- struct{}{}
	}()
	return &reader, nil
}

func (r *FileReader) Close() {
	close(r.LineChan)