callbackreader

Documentation

Index

• type AfterFunc
• type BeforeFunc
• type CallbackReader
  • func New(r io.Reader) *CallbackReader
  • func (cr *CallbackReader) Close() error
  • func (cr *CallbackReader) OnAfter(fn AfterFunc)
  • func (cr *CallbackReader) OnBefore(fn BeforeFunc)
  • func (cr *CallbackReader) Read(p []byte) (int, error)
  • func (cr *CallbackReader) SetReader(reader io.Reader, closePreviousReader bool)

Types

type AfterFunc

type AfterFunc func(num int, p []byte, n int, err error) ([]byte, int, error)

AfterFunc runs after each read. num means the number of calling Read, starts from 1.

type BeforeFunc

type BeforeFunc func(num int, p []byte) []byte

BeforeFunc runs before each Read. num means the number of calling Read, starts from 1.

type CallbackReader

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

CallbackReader is counter for io.Reader

func New

func New(r io.Reader) *CallbackReader

New creates CallbackReader.

func (*CallbackReader) Close

func (cr *CallbackReader) Close() error

Close wraps Close if existed

func (*CallbackReader) OnAfter

func (cr *CallbackReader) OnAfter(fn AfterFunc)

OnAfter registers callback function running after the last read.

func (*CallbackReader) OnBefore

func (cr *CallbackReader) OnBefore(fn BeforeFunc)

OnBefore registers callback function running before the first read.

func (*CallbackReader) Read

func (cr *CallbackReader) Read(p []byte) (int, error)

func (*CallbackReader) SetReader

func (cr *CallbackReader) SetReader(reader io.Reader, closePreviousReader bool)

SetReader replace previous reader with new reader. If closePreviousReader set to true, it will close previous reader.