reader

Oct 25, 2024

Changes in this version

+ type CsvReader struct

+ func (r *CsvReader) Bind(ctx api.StreamContext, fileStream io.Reader, _ int) error

+ func (r *CsvReader) Close(ctx api.StreamContext) error

+ func (r *CsvReader) IsBytesReader() bool

+ func (r *CsvReader) Provision(ctx api.StreamContext, props map[string]any) error

+ func (r *CsvReader) Read(ctx api.StreamContext) (any, error)

+ type LinesReader struct

+ func (r *LinesReader) Bind(ctx api.StreamContext, fileStream io.Reader, maxSize int) error

+ func (r *LinesReader) Close(ctx api.StreamContext) error

+ func (r *LinesReader) IsBytesReader() bool

+ func (r *LinesReader) Provision(ctx api.StreamContext, props map[string]any) error

+ func (r *LinesReader) Read(ctx api.StreamContext) (any, error)