bufio

package

v1.2.21 Latest Latest Go to latest Published: May 27, 2022 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrMismatchTokenPair = errors.New("mismatch token pair")
	ErrInvalidStartToken = errors.New("invalid start token")
)

This section is empty.

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

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

A PairScanner reads and decodes Pair wrapped values from an input stream, like a json、xml.

func NewPairScanner(r io.Reader) *PairScanner

NewPairScanner returns a new scanner that reads from r.

The scanner introduces its own buffering and may read data from r beyond the JSON values requested.

func (pairScanner *PairScanner) Buffered() io.Reader

Buffered returns a reader of the data remaining in the PairScanner's buffer. The reader is valid until the next call to Decode.

func (pairScanner *PairScanner) Scan(pairs []DelimiterPair) (line []byte, err error)

Scan reads the next value complete wrapped by pair delimiters from its input and stores it in the value pointed to by v.

func (pairScanner *PairScanner) ScanDelimiters(delimiters string) (line []byte, err error)

func (pairScanner *PairScanner) SetDiscardLeading(discard bool) *PairScanner

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

func NewReaderPool() *ReaderPool

func NewReaderPoolSize(size int) *ReaderPool

func (p *ReaderPool) Clear()

func (p *ReaderPool) Get(r io.Reader) *bufio.Reader

func (p *ReaderPool) Put(br *bufio.Reader)

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

func NewWriterPool() *WriterPool

func NewWriterPoolSize(size int) *WriterPool

func (p *WriterPool) Clear()

func (p *WriterPool) Get(w io.Writer) *bufio.Writer

func (p *WriterPool) Put(br *bufio.Writer)