Documentation ¶
Overview ¶
Package breader (Buffered File Reader), asynchronous parsing and pre-processing while reading file. Safe cancellation is also supported.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultFunc = func(line string) (interface{}, bool, error) { line = strings.TrimRight(line, "\r\n") return line, true, nil }
DefaultFunc just trim the new line symbol
View Source
var ErrorCanceled = errors.New("reading canceled")
ErrorCanceled means that the reading process is canceled
Functions ¶
This section is empty.
Types ¶
type BufferedReader ¶
type BufferedReader struct { BufferSize int ChunkSize int ProcessFunc func(string) (interface{}, bool, error) Ch chan Chunk // contains filtered or unexported fields }
BufferedReader is BufferedReader
func NewBufferedReader ¶
func NewBufferedReader(file string, bufferSize int, chunkSize int, fn func(line string) (interface{}, bool, error)) (*BufferedReader, error)
NewBufferedReader is the constructor of BufferedReader with full parameters
func NewDefaultBufferedReader ¶
func NewDefaultBufferedReader(file string) (*BufferedReader, error)
NewDefaultBufferedReader creates BufferedReader with default parameter
func (*BufferedReader) Cancel ¶
func (reader *BufferedReader) Cancel()
Cancel method cancel the reading process
Click to show internal directories.
Click to hide internal directories.