Reader

Documentation

Index

• Constants
• Variables
• type Iter
  • func NewIter(rd *Reader) Iter
  • func (iter *Iter) Loop() iter.Seq[byte]
• type Reader
  • func NewReader(r io.Reader) *Reader
  • func NewReaderConfigured(r io.Reader, bufferSize, maxEmptyConsecutiveReads int, maxByteReads int) *Reader
  • func (rd *Reader) Iter() Iter

Constants

const (
	DefaultBufSize                  int = 1024
	DefaultMaxConsecutiveEmptyReads int = 100
	DefaultByteReads                int = -1
)

Variables

var (
	ReachedMaxBytesRead             error = errors.New("Reached max bytes read")
	ReachedMaxConsecutiveEmptyReads error = errors.New("Reached max consecutive empty reads")
)

Types

type Iter

type Iter struct {
	Err error
	// contains filtered or unexported fields
}

func NewIter

func NewIter(rd *Reader) Iter

func (*Iter) Loop

func (iter *Iter) Loop() iter.Seq[byte]

type Reader

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

func NewReader

func NewReader(r io.Reader) *Reader

func NewReaderConfigured

func NewReaderConfigured(r io.Reader, bufferSize, maxEmptyConsecutiveReads int, maxByteReads int) *Reader

maxByteReads = -1 for no limit.

func (*Reader) Iter

func (rd *Reader) Iter() Iter