pipe

Jun 7, 2020

Changes in this version

+ type ExecPipe struct

+ func NewExecPipe(cmd *exec.Cmd) *ExecPipe

+ func (this *ExecPipe) Start() (err error)

+ func (this *ExecPipe) Stop() error

+ func (this *ExecPipe) WriteAndRead(b []byte) (resp []byte, err error)

+ type Pipe interface

+ Start func() error

+ Stop func() error

+ WriteAndRead func([]byte) ([]byte, error)

+ type Pipes struct

+ func NewPipes(pipes []Pipe) *Pipes

+ func (this *Pipes) AcquirePipe() Pipe

+ func (this *Pipes) ReleasePipe(p Pipe)

+ func (this *Pipes) Start() (err error)

+ func (this *Pipes) Stop() (err error)

+ func (this *Pipes) WriteAndRead(b []byte) (resp []byte, err error)