pipe

Documentation

Index

• type LockablePipe
  • func NewLockable(input io.Reader) *LockablePipe
  • func (l *LockablePipe) Flush() []byte
  • func (l *LockablePipe) Read(p []byte) (n int, err error)
  • func (l *LockablePipe) WaitForString(expected string, until time.Duration) error

Types

type LockablePipe

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

func NewLockable

func NewLockable(input io.Reader) *LockablePipe

func (*LockablePipe) Flush

func (l *LockablePipe) Flush() []byte

func (*LockablePipe) Read

func (l *LockablePipe) Read(p []byte) (n int, err error)

func (*LockablePipe) WaitForString

func (l *LockablePipe) WaitForString(expected string, until time.Duration) error