rereader

Documentation

Index

• type ReReadCloser
  • func NewReReadCloser(rc io.ReadCloser) *ReReadCloser
  • func (rc *ReReadCloser) Read(p []byte) (n int, err error)
• type ReReader
  • func NewReReader(r io.Reader) *ReReader
  • func (rr *ReReader) Read(p []byte) (n int, err error)

Types

type ReReadCloser

type ReReadCloser struct {
	io.ReadCloser
	// contains filtered or unexported fields
}

ReReadCloser is same as ReReader but also forwards Close calls

func NewReReadCloser

func NewReReadCloser(rc io.ReadCloser) *ReReadCloser

NewReReadCloser return a initialized ReReadCloser

func (*ReReadCloser) Read

func (rc *ReReadCloser) Read(p []byte) (n int, err error)

type ReReader

type ReReader struct {
	io.Reader
	// contains filtered or unexported fields
}

ReReader transparently buffers all reads from a reader until Restarted is set to true. When restarted buffered data will be replayed on read and after that normal reading from the reader continues.

func NewReReader

func NewReReader(r io.Reader) *ReReader

NewReReader return a initialized ReReader

func (*ReReader) Read

func (rr *ReReader) Read(p []byte) (n int, err error)