buffer

type LimitWriterOption ¶

type LimitWriterOption func(*LimitedWriter)

type LimitedWriter ¶

type LimitedWriter struct {
	W    io.Writer // underlying reader
	N    int64     // max bytes remaining
	MaxN int64     // max bytes remaining
	// contains filtered or unexported fields
}

A LimitedWriter reads from R but limits the amount of data returned to just N bytes. Each call to Read updates N to reflect the new amount remaining. Read returns EOF when N <= 0 or when the underlying R returns EOF.

func (l *LimitedWriter) Write(p []byte) (n int, err error)

type PreReader ¶

type PreReader interface {
	io.ReadCloser
	Buffer() []byte
	String() string
}

func NewPreReader(reader io.ReadCloser, maxLen int) (PreReader, error)

@Description[en-US]: Convert a io.ReadCloser to an io.ReadCloser that can read data in advance
@Description[zh-CN]: 将一个 io.ReadCloser 转换为可预读数据的 io.ReadCloser
@param reader 	io.ReadCloser
@param maxLen 	int
@return ${r}	PreReader
@return ${err}	error