text

type Reader struct {
	// contains filtered or unexported fields
}

type ReaderOptions struct {
	// Reader from which data is readed
	Reader io.Reader
	// AutoClose if its true and Reader implements io.Closer
	// io.Reader.Close() method is called on Process finish
	AutoClose bool
	// Default is ScanLines
	SplitFunc bufio.SplitFunc
	// ReadFormat process every data point with this function
	// default is nil , raw message is passed to WriteFormat
	ReadFormat selina.Unmarshaler
	// WriteFormat by default is json.Marshal
	WriteFormat selina.Marshaler
}

type Writer struct {
	// contains filtered or unexported fields
}

type WriterOptions struct {
	// Writer io.Writer where data will be written
	Writer io.Writer
	// AutoClose when true and Writer implements io.Closer
	// io.Closer.Close() method will be called on finalization
	AutoClose   bool
	SkipNewLine bool
	BufferSize  int
	Codec       selina.Marshaler
}