newCsvReaderWithDelimiter creates a csvReader from a given ReadCloser, |r|, using the |delimiter| as the field delimiter in the parsed data.
(r io.ReadCloser, delimiter string)
| 82 | // newCsvReaderWithDelimiter creates a csvReader from a given ReadCloser, |r|, using |
| 83 | // the |delimiter| as the field delimiter in the parsed data. |
| 84 | func newCsvReaderWithDelimiter(r io.ReadCloser, delimiter string) (*csvReader, error) { |
| 85 | textReader := transform.NewReader(r, textunicode.BOMOverride(transform.Nop)) |
| 86 | br := bufio.NewReaderSize(textReader, csvReadBufSize) |
| 87 | |
| 88 | return &csvReader{ |
| 89 | closer: r, |
| 90 | bRd: br, |
| 91 | isDone: false, |
| 92 | delim: []byte(delimiter), |
| 93 | }, nil |
| 94 | } |
| 95 | |
| 96 | func (csvr *csvReader) ReadSqlRow() (sql.Row, error) { |
| 97 | if csvr.isDone { |
no outgoing calls
no test coverage detected