blocking

Documentation

Index

• type Reader
  • func New(r io.Reader) Reader
  • func (r Reader) Read(data []byte) (int, error)

Types

type Reader

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

Reader is an io.Reader that blocks until the underlying reader until returns something other than io.EOF.

on EOF, it'll keep trying to read every 10ms.

The purpose of this is to be used to "emulate a STDIN" (which never EOFs) from another io.Reader, e.g. a bytes.Buffer.

func New

func New(r io.Reader) Reader

New wraps a given io.Reader into a BlockingReader.

func (Reader) Read

func (r Reader) Read(data []byte) (int, error)