reader

Documentation

Index

• Variables
• type FrozenReader
  • func (reader FrozenReader) Read(p []byte) (n int, err error)
• type KeyPressReader
  • func (reader KeyPressReader) Read(p []byte) (n int, err error)
  • func (reader *KeyPressReader) Start() error
  • func (reader *KeyPressReader) Stop() error
• type ReusableReadCloser
  • func NewReusableReadCloser(raw interface{}) (*ReusableReadCloser, error)
  • func (r ReusableReadCloser) Close() error
  • func (r ReusableReadCloser) Read(p []byte) (int, error)
• type TimeoutReader
  • func (reader TimeoutReader) Read(p []byte) (n int, err error)

Variables

var ErrTimeout = errors.New("Timeout")

Types

type FrozenReader

type FrozenReader struct{}

FrozenReader is a reader that never returns

func (FrozenReader) Read

func (reader FrozenReader) Read(p []byte) (n int, err error)

Read into the buffer

type KeyPressReader

type KeyPressReader struct {
	Timeout time.Duration

	Once       *sync.Once
	Raw        bool
	BufferSize int
	// contains filtered or unexported fields
}

func (KeyPressReader) Read

func (reader KeyPressReader) Read(p []byte) (n int, err error)

Read into the buffer

func (*KeyPressReader) Start

func (reader *KeyPressReader) Start() error

func (*KeyPressReader) Stop

func (reader *KeyPressReader) Stop() error

type ReusableReadCloser

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

ReusableReadCloser is a reusable reader with no-op close

func NewReusableReadCloser

func NewReusableReadCloser(raw interface{}) (*ReusableReadCloser, error)

NewReusableReadCloser is returned for any type of input

func (ReusableReadCloser) Close

func (r ReusableReadCloser) Close() error

Close is a no-op close of ReusableReadCloser

func (ReusableReadCloser) Read

func (r ReusableReadCloser) Read(p []byte) (int, error)

Read []byte from Reader

type TimeoutReader

type TimeoutReader struct {
	Timeout time.Duration
	Reader  io.Reader
	// contains filtered or unexported fields
}

TimeoutReader is a reader wrapper that stops waiting after Timeout

func (TimeoutReader) Read

func (reader TimeoutReader) Read(p []byte) (n int, err error)

Read into the buffer