const (
StatusStopped = iota
StatusRunning
StatusStopping
)
BGReader is an io.Reader that can optionally buffer reads in the background. It is safe for concurrent use.
type BGReader struct {
// contains filtered or unexported fields
}
func New(r io.Reader) *BGReader
func (r *BGReader) Read(p []byte) (int, error)
Read implements the io.Reader interface.
func (r *BGReader) Start()
Start starts the backgrounder reader. If the background reader is already running this is a no-op. The background reader will stop automatically when the underlying reader returns an error.
func (r *BGReader) Status() int32
Status returns the current status of the background reader.
func (r *BGReader) Stop()
Stop tells the background reader to stop after the in progress Read returns. It is safe to call Stop when the background reader is not running.