Versions in this module Expand all Collapse all v0 v0.0.1 Feb 6, 2024 Changes in this version + var ErrOnData = errors.New("OnData error") + var ErrOnRow = errors.New("OnRow error") + var ErrParse = errors.New("Parse error") + type FileStream string + func (fs FileStream) Open() (io.ReadCloser, error) + type HTTPStream string + func (hs HTTPStream) Open() (io.ReadCloser, error) + type Parser struct + OnData func(data T) error + OnError func(error) + OnRow func(row []string) error + Parse func(row []string) (T, error) + Reader *csv.Reader + func New[T any](stream Stream) (*Parser[T], error) + func (p *Parser[T]) Run(ctx context.Context, workers int) error + type Stream interface + Open func() (io.ReadCloser, error) + func ReadStream(r io.Reader) Stream